NE

apache · Feb 13, 2025 · bb43252 · bb43252
1 parent 7be7a49
commit bb43252
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/be/src/vec/exec/scan/scanner_context.cpp b/be/src/vec/exec/scan/scanner_context.cpp
@@ -534,10 +534,11 @@ Status ScannerContext::_schedule_scan_task(std::shared_ptr<ScanTask> current_sca
         // This DCHECK is necessary.
         // We need to make sure each scan operator could have at least 1 scan tasks.
         // Or this scan operator will not be re-scheduled.
-        if (!_pending_scanners.empty() && _num_scheduled_scanners == 0) {
+        if (!_pending_scanners.empty() && _num_scheduled_scanners == 0 && _tasks_queue.empty()) {
             throw doris::Exception(ErrorCode::INTERNAL_ERROR, "Scanner schduler logical error.");
         }
 #endif
+
         return Status::OK();
     }