[Bugfix][Zeta] Fix the checkpoint blocking with long time (apache#5694)

happyboy1024 · Oct 24, 2023 · 1f16aeb · 1f16aeb
1 parent 7262bd9
commit 1f16aeb
Showing 1 changed file with 8 additions and 0 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
@@ -152,6 +152,14 @@ public void collect() throws Exception {
                 Thread.sleep(100);
             } else {
                 collector.resetEmptyThisPollNext();
+                /**
+                 * The current thread obtain a checkpoint lock in the method {@link
+                 * SourceReader#pollNext(Collector)}. When trigger the checkpoint or savepoint,
+                 * other threads try to obtain the lock in the method {@link
+                 * SourceFlowLifeCycle#triggerBarrier(Barrier)}. When high CPU load, checkpoint
+                 * process may be blocked as long time. So we need sleep to free the CPU.
+                 */
+                Thread.sleep(0L);
             }
 
             if (collector.captureSchemaChangeBeforeCheckpointSignal()) {