(doris) 17/27: [Optimize](kill-query)Support the scanners exits as soon as possible when kill query #29803

[yiguolei]

This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git

commit ad2c13e009eeaf97dabfce9b6333779bf4796aed
Author: Xujian Duan <50550370+darvend...@users.noreply.github.com>
AuthorDate: Thu Jan 11 20:47:42 2024 +0800

    [Optimize](kill-query)Support the scanners exits as soon as possible when 
kill query #29803
---
 be/src/vec/exec/scan/vfile_scanner.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/be/src/vec/exec/scan/vfile_scanner.cpp 
b/be/src/vec/exec/scan/vfile_scanner.cpp
index 57f079d77af..73ad94d9cbe 100644
--- a/be/src/vec/exec/scan/vfile_scanner.cpp
+++ b/be/src/vec/exec/scan/vfile_scanner.cpp
@@ -282,6 +282,7 @@ void VFileScanner::_get_slot_ids(VExpr* expr, 
std::vector<int>* slot_ids) {
 }
 
 Status VFileScanner::open(RuntimeState* state) {
+    RETURN_IF_CANCELLED(state);
     RETURN_IF_ERROR(VScanner::open(state));
     RETURN_IF_ERROR(_init_expr_ctxes());
 
@@ -309,6 +310,7 @@ Status VFileScanner::open(RuntimeState* state) {
 // _convert_to_output_block     -     -    -  -                 -              
  -      x
 Status VFileScanner::_get_block_impl(RuntimeState* state, Block* block, bool* 
eof) {
     do {
+        RETURN_IF_CANCELLED(state);
         if (_cur_reader == nullptr || _cur_reader_eof) {
             RETURN_IF_ERROR(_get_next_reader());
         }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org