(amoro) branch master updated: Fix: The issue of startup failure caused by upgrading the iceberg version. (#3262)

[jinsongzhou]

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

jinsongzhou 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 8954349d9 Fix: The issue of startup failure caused by upgrading the 
iceberg version. (#3262)
8954349d9 is described below

commit 8954349d975c7b8a7e924b9d70455aad173bf36f
Author: Darcy <linting...@lilith.com>
AuthorDate: Wed Oct 16 18:44:29 2024 +0800

    Fix: The issue of startup failure caused by upgrading the iceberg version. 
(#3262)
    
    fix: The issue of startup failure caused by upgrading the iceberg version.
---
 .../org/apache/amoro/server/optimizing/OptimizingQueue.java   | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

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 2dcfcaca8..fb844a41a 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
@@ -666,12 +666,13 @@ public class OptimizingQueue extends PersistentBase {
     }
 
     private void loadTaskRuntimes(OptimizingProcess optimizingProcess) {
-      List<TaskRuntime<RewriteStageTask>> taskRuntimes =
-          getAs(
-              OptimizingMapper.class,
-              mapper ->
-                  
mapper.selectTaskRuntimes(tableRuntime.getTableIdentifier().getId(), 
processId));
       try {
+        List<TaskRuntime<RewriteStageTask>> taskRuntimes =
+            getAs(
+                OptimizingMapper.class,
+                mapper ->
+                    mapper.selectTaskRuntimes(
+                        tableRuntime.getTableIdentifier().getId(), processId));
         Map<Integer, RewriteFilesInput> inputs = 
TaskFilesPersistence.loadTaskInputs(processId);
         taskRuntimes.forEach(
             taskRuntime -> {