fix

dataroaring · Sep 15, 2023 · f5d5b50 · f5d5b50
1 parent 642664f
commit f5d5b50
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/be/src/pipeline/exec/scan_operator.h b/be/src/pipeline/exec/scan_operator.h
@@ -99,7 +99,7 @@ struct DataReadyDependency : public Dependency {
 
  [[nodiscard]] Dependency* read_blocked_by() override {
  if (_scanner_ctx->get_num_running_scanners() == 0 &&
- _scanner_ctx->has_enough_space_in_blocks_queue()) {
+ _scanner_ctx->should_be_scheduled()) {
  _scanner_ctx->reschedule_scanner_ctx();
  }
  return _ready_for_read ? nullptr : this;