Fix code review problems

apache · Oct 16, 2023 · 37b8e70 · 37b8e70
1 parent 945cdbc
commit 37b8e70
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 14 deletions.
diff --git a/pom.xml b/pom.xml
@@ -730,8 +730,6 @@
                     <encoding>UTF-8</encoding>
                 </configuration>
             </plugin>
-            <!-- disable spotless check during release -->
-            <!--
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-release-plugin</artifactId>
@@ -748,7 +746,6 @@
                     </dependency>
                 </dependencies>
             </plugin>
-            -->
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-surefire-plugin</artifactId>

diff --git a/...e/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/JobStatus.java b/...e/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/...ne-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java b/...ne-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/...-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/SubPlan.java b/...-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: