(amoro) branch master updated: [AMORO-3367] Avoid throwing StringIndexOutOfBoundsException in flink optimizer executors (#3368)

[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 cf9529381 [AMORO-3367] Avoid throwing StringIndexOutOfBoundsException 
in flink optimizer executors (#3368)
cf9529381 is described below

commit cf95293810c518bc43e4cd0e1c5e5d32c1248292
Author: Xavier Bai <x...@apache.org>
AuthorDate: Fri Dec 20 11:29:54 2024 +0800

    [AMORO-3367] Avoid throwing StringIndexOutOfBoundsException in flink 
optimizer executors (#3368)
    
    Co-authored-by: ZhouJinsong <zhoujinsong0...@163.com>
---
 .../java/org/apache/amoro/optimizer/flink/FlinkOptimizerExecutor.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/amoro-optimizer/amoro-optimizer-flink/src/main/java/org/apache/amoro/optimizer/flink/FlinkOptimizerExecutor.java
 
b/amoro-optimizer/amoro-optimizer-flink/src/main/java/org/apache/amoro/optimizer/flink/FlinkOptimizerExecutor.java
index 824a73b59..cb2fff27e 100644
--- 
a/amoro-optimizer/amoro-optimizer-flink/src/main/java/org/apache/amoro/optimizer/flink/FlinkOptimizerExecutor.java
+++ 
b/amoro-optimizer/amoro-optimizer-flink/src/main/java/org/apache/amoro/optimizer/flink/FlinkOptimizerExecutor.java
@@ -75,8 +75,9 @@ public class FlinkOptimizerExecutor extends OptimizerExecutor 
{
       if (runtimeContext != null && !runtimeContext.isEmpty()) {
         runtimeContext.forEach((k, v) -> 
sb.append(k).append("=").append(v).append("\n"));
       }
+      String errorMsg = sb + result.getErrorMessage();
       result.setErrorMessage(
-          (sb + result.getErrorMessage()).substring(0, 
ERROR_MESSAGE_MAX_LENGTH));
+          errorMsg.substring(0, Math.min(ERROR_MESSAGE_MAX_LENGTH, 
errorMsg.length())));
     }
     return result;
   }