[Hotfix][Seatunnel-engine] Optimize the code

apache · Jun 13, 2024 · 6812e03 · 6812e03
1 parent 526c5de
commit 6812e03
Showing 1 changed file with 4 additions and 11 deletions.
diff --git a/...erver/src/main/java/org/apache/seatunnel/engine/server/task/flow/SourceFlowLifeCycle.java b/...erver/src/main/java/org/apache/seatunnel/engine/server/task/flow/SourceFlowLifeCycle.java
@@ -310,18 +310,11 @@ public void triggerBarrier(Barrier barrier) throws Exception {
                         "lock checkpoint[{}] waiting for complete..., phase: [{}]",
                         barrier.getId(),
                         schemaChangePhase.get().getPhase());
-            } else if (prepareClose) {
-                TaskLocation taskLocation = runningTask.getTaskLocation();
-                log.info(
-                        "Task[{}]({}/{}) prepare close",
-                        taskLocation.getTaskID(),
-                        taskLocation.getPipelineId(),
-                        taskLocation.getJobId());
             } else {
-                throw new IllegalStateException(
-                        String.format(
-                                "schema-change checkpoint[%s] and phase[%s] is not matched",
-                                barrier.getId(), checkpointType));
+                log.debug(
+                        "Ignore schema-change checkpoint[{}], phase: [{}]",
+                        barrier.getId(),
+                        checkpointType);
             }
         }
     }