diff --git a/pom.xml b/pom.xml index efa1d71a1efb..adcdd5e7e05c 100644 --- a/pom.xml +++ b/pom.xml @@ -730,8 +730,6 @@ UTF-8 - - org.apache.maven.plugins maven-surefire-plugin diff --git a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/JobStatus.java b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/JobStatus.java index 43a5e0717588..e9801629b102 100644 --- a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/JobStatus.java +++ b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/JobStatus.java @@ -29,7 +29,10 @@ public enum JobStatus { /** Job is newly created, no task has started to run. */ CREATED(EndState.NOT_END), - /** Job will scheduler every pipeline */ + /** + * Job will scheduler every pipeline, each PhysicalVertex in the pipeline will be scheduler and + * deploying + */ SCHEDULED(EndState.NOT_END), /** The job is already running, and each pipeline is already running. */ diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java index 5d1225776061..72de3f8658aa 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java +++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java @@ -300,11 +300,6 @@ private synchronized void stateProcess() { updateJobState(JobStatus.RUNNING); break; case RUNNING: - try { - Thread.sleep(200); - } catch (InterruptedException e) { - makeJobFailing(e); - } break; case FAILING: case CANCELING: diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/SubPlan.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/SubPlan.java index b1fe950c32cd..0f9141ed00b8 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/SubPlan.java +++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/SubPlan.java @@ -609,11 +609,6 @@ private synchronized void stateProcess() { updatePipelineState(PipelineStatus.RUNNING); break; case RUNNING: - try { - Thread.sleep(200); - } catch (InterruptedException e) { - makePipelineFailing(e); - } break; case FAILING: case CANCELING: