Browse Source
Merge pull request #16044 from AndriiLandiak/fix/sync-not-stranded-on-fetcher-failure-lts-4.2
Do not strand edge sync when an event fetcher fails
pull/15658/merge
Viacheslav Klimov
1 week ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with
6 additions and
1 deletions
-
application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcSession.java
|
|
@ -269,7 +269,12 @@ public abstract class EdgeGrpcSession implements Closeable { |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public void onFailure(Throwable t) { |
|
|
public void onFailure(Throwable t) { |
|
|
log.error("[{}][{}] Exception during sync process", tenantId, edge.getId(), t); |
|
|
log.error("[{}][{}] Exception during sync process, skipping fetcher {} and continuing", |
|
|
|
|
|
tenantId, edge.getId(), next.getClass().getSimpleName(), t); |
|
|
|
|
|
// Keep walking the cursor: returning here leaves syncInProgress set for the life of the
|
|
|
|
|
|
// session, so the edge never receives SyncCompletedMsg and both general downlink delivery
|
|
|
|
|
|
// and uplink processing stay gated until the session is re-established.
|
|
|
|
|
|
doSync(cursor); |
|
|
} |
|
|
} |
|
|
}, ctx.getGrpcCallbackExecutorService()); |
|
|
}, ctx.getGrpcCallbackExecutorService()); |
|
|
} else { |
|
|
} else { |
|
|
|
