From 7c52b9f36e3ebe83faae655b3b0b1fdf0620959e Mon Sep 17 00:00:00 2001
From: meiyi <myimeiyi@gmail.com>
Date: Wed, 8 May 2024 21:48:06 +0800
Subject: [PATCH] [fix](txn insert) Txn insert stuck if execute on observer fe
 (#34547)

---
 .../main/java/org/apache/doris/analysis/NativeInsertStmt.java   | 2 +-
 .../suites/insert_p0/insert_group_commit_into.groovy            | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/NativeInsertStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/NativeInsertStmt.java
index 329f93088b..4c0574b4e1 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/NativeInsertStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/NativeInsertStmt.java
@@ -1157,7 +1157,7 @@ public class NativeInsertStmt extends InsertStmt {
 
     @Override
     public RedirectStatus getRedirectStatus() {
-        if (isExplain() || isGroupCommit()) {
+        if (isExplain() || isGroupCommit() || (ConnectContext.get() != null && ConnectContext.get().isTxnModel())) {
             return RedirectStatus.NO_FORWARD;
         } else {
             return RedirectStatus.FORWARD_WITH_SYNC;
diff --git a/regression-test/suites/insert_p0/insert_group_commit_into.groovy b/regression-test/suites/insert_p0/insert_group_commit_into.groovy
index dc681feb3f..5c60ff82bb 100644
--- a/regression-test/suites/insert_p0/insert_group_commit_into.groovy
+++ b/regression-test/suites/insert_p0/insert_group_commit_into.groovy
@@ -47,7 +47,7 @@ suite("insert_group_commit_into") {
                 return true
             }
             retry++
-            if (retry >= 10) {
+            if (retry >= 20) {
                 return false
             }
         }