This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 3eb24bff707 [fix](schema scan) Finish schema scanner if limitation is
reached (#41592)
3eb24bff707 is described below
commit 3eb24bff707b95ac6fb5afc8f5504ed4133f8402
Author: Gabriel <[email protected]>
AuthorDate: Wed Oct 9 17:21:56 2024 +0800
[fix](schema scan) Finish schema scanner if limitation is reached (#41592)
---
be/src/pipeline/exec/schema_scan_operator.cpp | 3 +++
1 file changed, 3 insertions(+)
diff --git a/be/src/pipeline/exec/schema_scan_operator.cpp
b/be/src/pipeline/exec/schema_scan_operator.cpp
index fcc1ed2bbb1..006ecf8ad82 100644
--- a/be/src/pipeline/exec/schema_scan_operator.cpp
+++ b/be/src/pipeline/exec/schema_scan_operator.cpp
@@ -266,6 +266,9 @@ Status SchemaScanOperatorX::get_block(RuntimeState* state,
vectorized::Block* bl
} while (block->rows() == 0 && !*eos);
local_state.reached_limit(block, eos);
+ if (*eos) {
+ local_state._finish_dependency->set_always_ready();
+ }
return Status::OK();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
