diff --git a/be/src/vec/sink/load_stream_stub.cpp b/be/src/vec/sink/load_stream_stub.cpp index 347acb1b6f..c4b1016229 100644 --- a/be/src/vec/sink/load_stream_stub.cpp +++ b/be/src/vec/sink/load_stream_stub.cpp @@ -316,6 +316,10 @@ Status LoadStreamStub::close_wait(int64_t timeout_ms) { if (_is_closed.load()) { return _check_cancel(); } + // if there are other sinks remaining, let the last sink handle close wait + if (_use_cnt > 0) { + return Status::OK(); + } if (timeout_ms <= 0) { timeout_ms = config::close_load_stream_timeout_ms; }