You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by fa...@apache.org on 2023/03/30 03:08:51 UTC
[incubator-seatunnel] branch dev updated: [Zeta] [Fix] Fix handleCheckpointError be called while checkpoint already complete (#4442)
This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 4da5b0c64 [Zeta] [Fix] Fix handleCheckpointError be called while checkpoint already complete (#4442)
4da5b0c64 is described below
commit 4da5b0c64d88ff2fb34add55330127186883d2ff
Author: Eric <ga...@gmail.com>
AuthorDate: Thu Mar 30 11:08:45 2023 +0800
[Zeta] [Fix] Fix handleCheckpointError be called while checkpoint already complete (#4442)
---
.../seatunnel/engine/server/checkpoint/CheckpointCoordinator.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java
index 553cd5e0b..42ff998b9 100644
--- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java
+++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java
@@ -212,6 +212,9 @@ public class CheckpointCoordinator {
}
private void handleCoordinatorError(CheckpointCloseReason reason, Throwable e) {
+ if (checkpointCoordinatorFuture.isDone()) {
+ return;
+ }
CheckpointException checkpointException = new CheckpointException(reason, e);
cleanPendingCheckpoint(reason);
checkpointCoordinatorFuture.complete(