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 13e271110 [AMORO-3033]IndexOutOfBoundsException when start up AMS 
during selectProcessInputFiles  because of no optimizing process_id (#3034)
13e271110 is described below

commit 13e271110ebee87d52af57840a6b8be61f18f3a2
Author: Xie Yi <[email protected]>
AuthorDate: Mon Jul 15 15:58:23 2024 +0800

    [AMORO-3033]IndexOutOfBoundsException when start up AMS during 
selectProcessInputFiles  because of no optimizing process_id (#3034)
    
    fix IndexOutOfBoundsException when start ams
---
 .../java/org/apache/amoro/server/persistence/TaskFilesPersistence.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/persistence/TaskFilesPersistence.java
 
b/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/persistence/TaskFilesPersistence.java
index 9e8f040aa..5bbba3abd 100644
--- 
a/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/persistence/TaskFilesPersistence.java
+++ 
b/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/persistence/TaskFilesPersistence.java
@@ -46,7 +46,7 @@ public class TaskFilesPersistence {
     List<byte[]> bytes =
         persistence.getAs(
             OptimizingMapper.class, mapper -> 
mapper.selectProcessInputFiles(processId));
-    if (bytes == null) {
+    if (bytes == null || bytes.isEmpty()) {
       return Collections.emptyMap();
     } else {
       return 
SerializationUtil.simpleDeserialize(CompressUtil.unGzip(bytes.get(0)));

Reply via email to