diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
index fdc94232990435..c0470ecf57bf25 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
@@ -381,7 +381,9 @@ public void executeQuery(String originStmt) throws Exception {
                     auditAfterExec(auditStmt, executor.getParsedStmt(), executor.getQueryStatisticsForAuditLog(),
                             true);
                     // execute failed, skip remaining stmts
-                    if (ctx.getState().getStateType() == MysqlStateType.ERR) {
+                    if (ctx.getState().getStateType() == MysqlStateType.ERR || (!Env.getCurrentEnv().isMaster()
+                            && ctx.executor != null && ctx.executor.isForwardToMaster()
+                            && ctx.executor.getProxyStatusCode() != 0)) {
                         break;
                     }
                 } catch (Throwable throwable) {
diff --git a/regression-test/data/insert_p0/insert.out b/regression-test/data/insert_p0/insert.out
index b582f45123dc66..bd2216290c7080 100644
--- a/regression-test/data/insert_p0/insert.out
+++ b/regression-test/data/insert_p0/insert.out
@@ -202,3 +202,9 @@
 44980	113.8777	again	1987-04-09	2010-01-02T04:03:06	false	-0.01	0E-10
 44980	113.8777	again	1987-04-09	2010-01-02T04:03:06	false	-0.01	0E-10
 
+-- !select1 --
+1994-12-08	1	1
+1994-12-14	1	1
+1994-12-14	2	1
+2000-12-08	1	1
+
diff --git a/regression-test/suites/insert_p0/insert.groovy b/regression-test/suites/insert_p0/insert.groovy
index 28823815677740..2ac28c1f72b74b 100644
--- a/regression-test/suites/insert_p0/insert.groovy
+++ b/regression-test/suites/insert_p0/insert.groovy
@@ -114,7 +114,20 @@ suite("insert") {
         """
 
     sql """
+    DROP TABLE IF EXISTS source;
     DROP TABLE IF EXISTS dest;
+    CREATE TABLE source (
+                l_shipdate    DATE NOT NULL,
+                        l_orderkey    bigint NOT NULL,
+                l_linenumber  int not null
+        )ENGINE=OLAP
+        DUPLICATE KEY(`l_shipdate`, `l_orderkey`)
+        COMMENT "OLAP"
+        DISTRIBUTED BY HASH(`l_orderkey`) BUCKETS 96
+        PROPERTIES (
+                "replication_num" = "1"
+        );
+
     CREATE TABLE dest (
                 l_shipdate    DATE NOT NULL,
                         l_orderkey    bigint NOT NULL,
@@ -127,10 +140,20 @@ suite("insert") {
         PROPERTIES (
                 "replication_num" = "1"
         );
+    insert into source values('1994-12-08', 1,1) , ('1994-12-14',1,1), ('1994-12-14',2,1);
    """
 
     test {
         sql("insert into dest values(now(), 0xff, 0xaa)")
         exception "Unknown column '0xff' in 'table list' in UNBOUND_OLAP_TABLE_SINK clause"
     }
+
+    try {
+        sql """ insert into source values('2000-12-08', 1, 1);
+            insert into source values('2000-12-09', 1, 1, 100);
+            insert into source values('2000-12-10', 1, 1); """
+    } catch (Exception e) {
+        logger.info("exception: " + e.getMessage())
+    }
+    order_qt_select1 """ select * from source; """
 }