From fc2d689d4a0bdee2042ffb8ddedd98b04f0a4a01 Mon Sep 17 00:00:00 2001 From: wangxin Date: Sat, 17 Apr 2021 11:50:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dpbe=E5=9C=BA=E6=99=AF?= =?UTF-8?q?=E4=B8=8B=E5=8D=95=E6=9C=BAsmp=E4=BD=BF=E7=94=A8limit=E5=87=BA?= =?UTF-8?q?=E7=8E=B0hang=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/process/tcop/postgres.cpp | 8 -------- 1 file changed, 8 deletions(-) diff --git a/src/gausskernel/process/tcop/postgres.cpp b/src/gausskernel/process/tcop/postgres.cpp index e0854e147..f14106f55 100644 --- a/src/gausskernel/process/tcop/postgres.cpp +++ b/src/gausskernel/process/tcop/postgres.cpp @@ -4849,14 +4849,6 @@ static void exec_execute_message(const char* portal_name, long max_rows) u_sess->xact_cxt.pbe_execute_complete = false; } -#ifndef ENABLE_MULTIPLE_NODES - if (u_sess->xact_cxt.pbe_execute_complete == true) { - /* Set sync point for waiting all stream threads complete. */ - StreamNodeGroup::syncQuit(STREAM_COMPLETE); - UnRegisterStreamSnapshots(); - } -#endif - if (ENABLE_WORKLOAD_CONTROL) { if (g_instance.wlm_cxt->dynamic_workload_inited) { if (t_thrd.wlm_cxt.parctl_state.simple == 0)