diff --git a/be/src/vec/exec/scan/scanner_scheduler.cpp b/be/src/vec/exec/scan/scanner_scheduler.cpp index 81d72984a719217..251599ebf3017ab 100644 --- a/be/src/vec/exec/scan/scanner_scheduler.cpp +++ b/be/src/vec/exec/scan/scanner_scheduler.cpp @@ -141,6 +141,8 @@ Status ScannerScheduler::submit(std::shared_ptr ctx) { if (ctx->done()) { return Status::EndOfFile("ScannerContext is done"); } + Status st = Status::InternalError("yyyy begin to schedule"); + LOG(INFO) << st; ctx->queue_idx = (_queue_idx++ % QUEUE_NUM); if (!_pending_queues[ctx->queue_idx]->blocking_put(ctx)) { return Status::InternalError("failed to submit scanner context to scheduler");