[Hotfix][Zeta] Fix job crash when schema changing on multiple paralle…

…l readers (apache#6977)
chaorongzhi · Aug 21, 2024 · 62a8532 · 62a8532
1 parent ad5c61d
commit 62a8532
Showing 1 changed file with 4 additions and 4 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
@@ -311,10 +311,10 @@ public void triggerBarrier(Barrier barrier) throws Exception {
                         barrier.getId(),
                         schemaChangePhase.get().getPhase());
             } 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[{}] on idle task, phase: [{}]",
+                        barrier.getId(),
+                        checkpointType);
             }
         }
     }