Update RetryUtils.java (apache#16368)

CRZbulabula · web-flow · commit b918b3b7caf9 · 2025-09-08T19:03:58.000+08:00
diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/RetryUtils.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/RetryUtils.java
@@ -33,7 +33,8 @@ public interface CallableWithException<T, E extends Exception> {
   public static boolean needRetryForWrite(int statusCode) {
     return statusCode == TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode()
         || statusCode == TSStatusCode.SYSTEM_READ_ONLY.getStatusCode()
-        || statusCode == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode();
+        || statusCode == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode()
+        || statusCode == TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode();
   }
 
   public static boolean needRetryWithIncreasingInterval(Exception e) {

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,8 @@ public interface CallableWithException<T, E extends Exception> {`
`33`	`33`	`public static boolean needRetryForWrite(int statusCode) {`
`34`	`34`	`return statusCode == TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode()`
`35`	`35`	`\|\| statusCode == TSStatusCode.SYSTEM_READ_ONLY.getStatusCode()`
`36`		`- \|\| statusCode == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode();`
	`36`	`+ \|\| statusCode == TSStatusCode.WRITE_PROCESS_REJECT.getStatusCode()`
	`37`	`+ \|\| statusCode == TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode();`
`37`	`38`	`}`
`38`	`39`
`39`	`40`	`public static boolean needRetryWithIncreasingInterval(Exception e) {`