This is an automated email from the ASF dual-hosted git repository.
panxiaolei 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 3089e4b3b6 [Bug](excution) fix ScannerContext is done make query
failed (#21923)
3089e4b3b6 is described below
commit 3089e4b3b6bb236dbf0fb596865357189134daaa
Author: Pxl <[email protected]>
AuthorDate: Tue Jul 18 17:58:00 2023 +0800
[Bug](excution) fix ScannerContext is done make query failed (#21923)
fix ScannerContext is done make query failed
---
be/src/vec/exec/scan/pip_scanner_context.h | 2 +-
be/src/vec/exec/scan/scanner_context.cpp | 6 +++---
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/be/src/vec/exec/scan/pip_scanner_context.h
b/be/src/vec/exec/scan/pip_scanner_context.h
index c720c22d04..b71b72ab3c 100644
--- a/be/src/vec/exec/scan/pip_scanner_context.h
+++ b/be/src/vec/exec/scan/pip_scanner_context.h
@@ -48,7 +48,7 @@ public:
set_status_on_error(Status::Cancelled("cancelled"), false);
}
- if (!_process_status.ok()) {
+ if (!status().ok()) {
return _process_status;
}
}
diff --git a/be/src/vec/exec/scan/scanner_context.cpp
b/be/src/vec/exec/scan/scanner_context.cpp
index 049283647c..2f535e4947 100644
--- a/be/src/vec/exec/scan/scanner_context.cpp
+++ b/be/src/vec/exec/scan/scanner_context.cpp
@@ -199,7 +199,7 @@ Status ScannerContext::get_block_from_queue(RuntimeState*
state, vectorized::Blo
// Wait for block from queue
if (wait) {
SCOPED_TIMER(_scanner_wait_batch_timer);
- while (!(!_blocks_queue.empty() || _is_finished ||
!_process_status.ok() ||
+ while (!(!_blocks_queue.empty() || _is_finished || !status().ok() ||
state->is_cancelled())) {
_blocks_queue_added_cv.wait(l);
}
@@ -231,7 +231,7 @@ bool ScannerContext::set_status_on_error(const Status&
status, bool need_lock) {
if (need_lock) {
l.lock();
}
- if (_process_status.ok()) {
+ if (this->status().ok()) {
_process_status = status;
_status_error = true;
_blocks_queue_added_cv.notify_one();
@@ -327,7 +327,7 @@ std::string ScannerContext::debug_string() {
" status: {}, _should_stop: {}, _is_finished: {}, free blocks: {},"
" limit: {}, _num_running_scanners: {}, _num_scheduling_ctx: {},
_max_thread_num: {},"
" _block_per_scanner: {}, _cur_bytes_in_queue: {},
MAX_BYTE_OF_QUEUE: {}",
- ctx_id, _scanners.size(), _blocks_queue.size(),
_process_status.ok(), _should_stop,
+ ctx_id, _scanners.size(), _blocks_queue.size(), status().ok(),
_should_stop,
_is_finished, _free_blocks.size_approx(), limit,
_num_running_scanners,
_num_scheduling_ctx, _max_thread_num, _block_per_scanner,
_cur_bytes_in_queue,
_max_bytes_in_queue);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
