[Bug](scan)fix some case query timeout of not schedule scanner

zhangstar333 · Dec 11, 2023 · b13a564 · b13a564
1 parent e158753
commit b13a564
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/be/src/pipeline/exec/scan_operator.cpp b/be/src/pipeline/exec/scan_operator.cpp
@@ -53,7 +53,7 @@ bool ScanOperator::can_read() {
             return false;
         }
     } else {
-        if (_node->_eos || _node->_scanner_ctx->done()) {
+        if (_node->_eos || _node->_scanner_ctx->done() || _node->_scanner_ctx->no_schedule()) {
             // _eos: need eos
             // _scanner_ctx->done(): need finish
             // _scanner_ctx->no_schedule(): should schedule _scanner_ctx