bug: Internal. Code: 1001, Text = Pipeline graph is not finished

[wubx]

Search before asking

• [X] I had searched in the issues and found no similar issues.

Version

v1.2.648-nightly

What's Wrong?

   0: databend_common_exception::exception_backtrace::capture
             at /data1/wubx/databend/src/common/exception/src/exception_backtrace.rs:82:17
   1: databend_common_exception::exception_code::<impl databend_common_exception::exception::ErrorCode>::Internal
             at /data1/wubx/databend/src/common/exception/src/exception_code.rs:35:30
   2: databend_query::pipelines::executor::executor_graph::RunningGraph::assert_finished_graph
             at /data1/wubx/databend/src/query/service/src/pipelines/executor/executor_graph.rs:813:26
   3: databend_query::pipelines::executor::query_pipeline_executor::QueryPipelineExecutor::execute
             at /data1/wubx/databend/src/query/service/src/pipelines/executor/query_pipeline_executor.rs:263:29
   4: databend_query::pipelines::executor::pipeline_executor::PipelineExecutor::execute
             at /data1/wubx/databend/src/query/service/src/pipelines/executor/pipeline_executor.rs:179:66
   5: databend_query::pipelines::executor::pipeline_pulling_executor::PipelinePullingExecutor::thread_function::{{closure}}
             at /data1/wubx/databend/src/query/service/src/pipelines/executor/pipeline_pulling_executor.rs:223:28
      core::ops::function::FnOnce::call_once
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/core/src/ops/function.rs:250:5
      databend_common_base::runtime::runtime_tracker::ThreadTracker::tracking_function::{{closure}}::{{closure}}
             at /data1/wubx/databend/src/common/base/src/runtime/runtime_tracker.rs:208:17
      databend_common_base::runtime::thread::Thread::named_spawn::{{closure}}
             at /data1/wubx/databend/src/common/base/src/runtime/thread.rs:78:21
      std::sys::backtrace::__rust_begin_short_backtrace
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/std/src/sys/backtrace.rs:155:18
   6: std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/std/src/thread/mod.rs:542:17
      <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/core/src/panic/unwind_safe.rs:272:9
      std::panicking::try::do_call
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/std/src/panicking.rs:553:40
      std::panicking::try
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/std/src/panicking.rs:517:19
      std::panic::catch_unwind
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/std/src/panic.rs:350:14
      std::thread::Builder::spawn_unchecked_::{{closure}}
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/std/src/thread/mod.rs:541:30
      core::ops::function::FnOnce::call_once{{vtable.shim}}
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/core/src/ops/function.rs:250:5
   7: <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/alloc/src/boxed.rs:2064:9
      <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/alloc/src/boxed.rs:2064:9
      std::sys::pal::unix::thread::Thread::new::thread_start
             at /rustc/cf2df68d1f5e56803c97d91e2b1a9f1c9923c533/library/std/src/sys/pal/unix/thread.rs:108:17
   8: start_thread
             at ./nptl/pthread_create.c:442:8
   9: __GI___clone3
             at ./misc/../sysdeps/unix/sysv/linux/x86_64/clone3.S:81
)

databend-query-c100.2024-10-22-18.0.log

How to Reproduce?

TPCH-300 Q9 with

spilling_file_format='parquet'

Are you willing to submit PR?

• [ ] Yes I am willing to submit a PR!