(amoro) branch master updated: Correct the status of table runtime after ams restarted. (#4043)

[klion26]

This is an automated email from the ASF dual-hosted git repository.

klion26 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git


The following commit(s) were added to refs/heads/master by this push:
     new 3d824b094 Correct the status of table runtime after ams restarted. 
(#4043)
3d824b094 is described below

commit 3d824b094335a83d565e26b09d83b01e2024dd60
Author: Darcy <linting...@lilith.com>
AuthorDate: Fri Feb 13 22:45:51 2026 +0800

    Correct the status of table runtime after ams restarted. (#4043)
---
 .../main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java | 1 +
 .../main/java/org/apache/amoro/server/table/DefaultTableRuntime.java  | 4 ++++
 2 files changed, 5 insertions(+)

diff --git 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java
 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java
index ec207705c..964d27c7b 100644
--- 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java
+++ 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java
@@ -500,6 +500,7 @@ public class OptimizingQueue extends PersistentBase {
       if (processState.getToSequence() != null) {
         toSequence = processState.getToSequence();
       }
+      this.status = processMeta.getStatus();
       if (this.status != ProcessStatus.KILLED) {
         tableRuntime.recover(this);
       }
diff --git 
a/amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableRuntime.java
 
b/amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableRuntime.java
index 6cf566eef..11c1a21cf 100644
--- 
a/amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableRuntime.java
+++ 
b/amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableRuntime.java
@@ -32,6 +32,7 @@ import 
org.apache.amoro.optimizing.TableRuntimeOptimizingState;
 import org.apache.amoro.optimizing.plan.AbstractOptimizingEvaluator;
 import org.apache.amoro.process.AmoroProcess;
 import org.apache.amoro.process.ProcessFactory;
+import org.apache.amoro.process.ProcessStatus;
 import org.apache.amoro.process.TableProcessStore;
 import org.apache.amoro.server.AmoroServiceConstants;
 import org.apache.amoro.server.optimizing.OptimizingProcess;
@@ -118,6 +119,9 @@ public class DefaultTableRuntime extends 
AbstractTableRuntime
       throw new IllegalStateException("Table runtime and processing are not 
matched!");
     }
     this.optimizingProcess = optimizingProcess;
+    if (this.optimizingProcess.getStatus() == ProcessStatus.SUCCESS) {
+      completeProcess(true);
+    }
   }
 
   @Override