修复pbe场景下单机smp使用limit出现hang的问题

This commit is contained in:
wangxin
2021-04-17 11:50:39 +08:00
parent 71ee36edc8
commit fc2d689d4a

View File

@ -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)