2

Author: morningman

fe/fe-core/src/main/java/org/apache/doris/DorisFE.java

@@ -63,7 +63,6 @@
 import java.nio.channels.FileLock;
 import java.nio.channels.OverlappingFileLockException;
 import java.nio.file.StandardOpenOption;
-
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;

fe/fe-core/src/main/java/org/apache/doris/httpv2/HttpServer.java

@@ -189,7 +189,7 @@ public void start() {
                 .properties(properties)
                 .registerShutdownHook(false)
                 .run(new String[]{});
-   }
+    }
 
     /**
      * Explicitly shutdown the HTTP server.

fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java

@@ -1182,7 +1182,7 @@ public void executeByLegacy(TUniqueId queryId) throws Exception {
             throw e;
         } catch (UserException e) {
             // insert into select
-            if (Config.isCloudMode() && e.getMessage().contains(FeConstants.CLOUD_RETRY_E230)) {
+            if (Config.isCloudMode() && SystemInfoService.needRetryWithReplan(e.getMessage())) {
                 throw e;
             }
             // analysis exception only print message, not print the stack
@@ -2533,7 +2533,7 @@ private void handleInsertStmt() throws Exception {
                 }
 
                 // cloud mode, insert into select meet -230, retry
-                if (Config.isCloudMode() && t.getMessage().contains(FeConstants.CLOUD_RETRY_E230)) {
+                if (Config.isCloudMode() && SystemInfoService.needRetryWithReplan(t.getMessage())) {
                     LOG.warn("insert into select meet E-230, retry again");
                     resetAnalyzerAndStmt();
                     if (insertStmt instanceof NativeInsertStmt) {