This is an automated email from the ASF dual-hosted git repository.
wanghailin 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 52610327d [Improve] [Zeta] Reduce CPU Cost When Task Not Ready (#4479)
52610327d is described below
commit 52610327dc07a24e7140b44acbecaec4c94b0a25
Author: Hisoka <[email protected]>
AuthorDate: Mon Apr 3 20:07:31 2023 +0800
[Improve] [Zeta] Reduce CPU Cost When Task Not Ready (#4479)
---
.../java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
index 9f332c684..dc07a5ea7 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
@@ -147,11 +147,15 @@ public abstract class SeaTunnelTask extends AbstractTask {
}
currState = READY_START;
reportTaskStatus(READY_START);
+ } else {
+ Thread.sleep(100);
}
break;
case READY_START:
if (startCalled) {
currState = STARTING;
+ } else {
+ Thread.sleep(100);
}
break;
case STARTING:
