[AMORO-3367] Avoid throwing StringIndexOutOfBoundsException in flink …

…optimizer executors (#3368) Co-authored-by: ZhouJinsong <[email protected]>
apache · Dec 20, 2024 · cf95293 · cf95293
1 parent a66fe6a
commit cf95293
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ptimizer-flink/src/main/java/org/apache/amoro/optimizer/flink/FlinkOptimizerExecutor.java b/...ptimizer-flink/src/main/java/org/apache/amoro/optimizer/flink/FlinkOptimizerExecutor.java
@@ -75,8 +75,9 @@ protected OptimizingTaskResult executeTask(OptimizingTask task) {
       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;
   }