[AMORO-3172] AMS ProcessStatus Miss Running Status

amoro-common/src/main/java/org/apache/amoro/process/ProcessStatus.java

@@ -18,16 +18,12 @@
 
 package org.apache.amoro.process;
 
-/**
- * Status of any {@link AmoroProcess}. Only UNKNOWN, RUNNING, FINISHED(SUCCESS, CLOSED, FAILED) are
- * necessary Stage classes are used to define multiple phases of one process such as OptimizingStage
- */
+/** Status of any {@link AmoroProcess}. */
 public enum ProcessStatus {
   UNKNOWN,
   PENDING,
-
-  /** This status containing scheduled and running phases */
-  ACTIVE,
+  RUNNING,
+  SUBMITTED,
   SUCCESS,
   CLOSED,
   FAILED

amoro-common/src/main/java/org/apache/amoro/process/TableProcess.java

@@ -31,7 +31,7 @@ public abstract class TableProcess<T extends TableProcessState> implements Amoro
   protected final TableRuntime tableRuntime;
   private final SimpleFuture submitFuture = new SimpleFuture();
   private final SimpleFuture completeFuture = new SimpleFuture();
-  private volatile ProcessStatus status = ProcessStatus.ACTIVE;
+  private volatile ProcessStatus status = ProcessStatus.RUNNING;
   private volatile String failedReason;
 
   protected TableProcess(T state, TableRuntime tableRuntime) {

amoro-common/src/main/java/org/apache/amoro/process/TableProcessState.java

@@ -32,7 +32,7 @@ public class TableProcessState implements ProcessState {
   private final ServerTableIdentifier tableIdentifier;
   @StateField private long startTime;
   @StateField private long endTime = -1L;
-  @StateField private ProcessStatus status = ProcessStatus.ACTIVE;
+  @StateField private ProcessStatus status = ProcessStatus.SUBMITTED;
   @StateField private volatile String failedReason;
   private volatile Map<String, String> summary;
 
@@ -108,7 +108,7 @@ protected void setStatus(ProcessStatus status) {
         || status == ProcessStatus.FAILED
         || status == ProcessStatus.CLOSED) {
       endTime = System.currentTimeMillis();
-    } else if (this.status != ProcessStatus.ACTIVE && status == ProcessStatus.ACTIVE) {
+    } else if (this.status != ProcessStatus.SUBMITTED && status == ProcessStatus.SUBMITTED) {
       endTime = -1L;
       failedReason = null;
       summary = null;

amoro-format-hudi/src/main/java/org/apache/amoro/formats/hudi/HudiTableDescriptor.java

@@ -447,7 +447,7 @@ protected OptimizingProcessInfo getOptimizingInfo(
       HoodieInstant inf =
           instantMap.get(instantTimestamp + "_" + HoodieInstant.State.INFLIGHT.name());
       if (inf != null) {
-        processInfo.setStatus(ProcessStatus.ACTIVE);
+        processInfo.setStatus(ProcessStatus.RUNNING);
       }
     }
     return processInfo;