From 70a5ecaf62447170cfda0cf810845612836b5b97 Mon Sep 17 00:00:00 2001 From: "arcoalien@qq.com" Date: Tue, 12 Sep 2023 19:19:15 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E5=86=99=E8=BD=AC=E5=8F=91?= =?UTF-8?q?=EF=BC=8C=E5=A4=87=E6=9C=BA=E6=89=A7=E8=A1=8C=E4=BA=8B=E5=8A=A1?= =?UTF-8?q?=E5=AE=8C=E6=88=90=E5=90=8E=E6=89=A7=E8=A1=8Cddl=E8=AF=AD?= =?UTF-8?q?=E5=8F=A5=E5=A4=B1=E8=B4=A5=E6=8A=A5=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/storage/replication/libpqsw.cpp | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/gausskernel/storage/replication/libpqsw.cpp b/src/gausskernel/storage/replication/libpqsw.cpp index b08333ba9..e03246af2 100644 --- a/src/gausskernel/storage/replication/libpqsw.cpp +++ b/src/gausskernel/storage/replication/libpqsw.cpp @@ -1094,6 +1094,10 @@ bool libpqsw_process_query_message(const char* commandTag, List* query_list, con libpqsw_set_set_command(false); libpqsw_set_redirect(false); + if (libpqsw_end_command(commandTag)) { + libpqsw_set_transaction(false); + } + if (get_redirect_manager()->ss_standby_state & SS_STANDBY_REQ_SELECT) { need_redirect = false; }