[incubator-seatunnel] branch dev updated: [Zeta] [Fix] Fix handleCheckpointError be called while checkpoint already complete (#4442)

[fanjia]

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 <gaojun2...@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(