[Bug] fix not close when pipeline context prepare failed (#17061)

2023-02-27 14:24:39 +08:00
parent f26f0a1059
commit b06f3da96c
1 changed files with 3 additions and 0 deletions
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@ -780,6 +780,9 @@ Status PipelineFragmentContext::submit() {
 }

 void PipelineFragmentContext::close_if_prepare_failed() {
+    if (_tasks.empty()) {
+        _root_plan->close(_runtime_state.get());
+    }
    for (auto& task : _tasks) {
        DCHECK(!task->is_pending_finish());
        WARN_IF_ERROR(task->close(), "close_if_prepare_failed failed: ");