diff --git a/be/src/vec/exec/scan/scanner_scheduler.cpp b/be/src/vec/exec/scan/scanner_scheduler.cpp index 63dd042d720252..4d07e66917dcd0 100644 --- a/be/src/vec/exec/scan/scanner_scheduler.cpp +++ b/be/src/vec/exec/scan/scanner_scheduler.cpp @@ -317,8 +317,7 @@ void ScannerScheduler::_scanner_scan(std::shared_ptr ctx, }, status); - if (status.is() || - status.is()) { + if (UNLIKELY(!status.ok())) { scan_task->set_status(status); eos = true; }