回合代码fixvacuum+limit语句不退出

2021-04-16 19:46:37 +08:00
parent 5af8c3d0d3
commit f94d4c96c7
24 changed files with 108 additions and 68 deletions
--- a/src/gausskernel/runtime/vecexecutor/vecnode/vecstream.cpp
+++ b/src/gausskernel/runtime/vecexecutor/vecnode/vecstream.cpp
@ -490,7 +490,11 @@ void ExecEndVecStream(VecStreamState* node)
 {
    if (IS_PGXC_DATANODE && node->consumer)
        node->consumer->deInit();
-
+#ifndef ENABLE_MULTIPLE_NODES
+    if (u_sess->stream_cxt.global_obj) {
+        u_sess->stream_cxt.global_obj->SigStreamThreadClose();
+    }
+#endif
    PlanState* outer_plan = outerPlanState(node);

    if (outer_plan != NULL)