[fix](txn insert) Txn insert stuck if execute on observer fe (#34547)

2024-05-08 21:48:06 +08:00
parent 95593f8e19
commit 7c52b9f36e
2 changed files with 2 additions and 2 deletions
--- 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;