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)));