From e4e57e9b05389d1b1ea65eb9a3e18360d3f8d1bd Mon Sep 17 00:00:00 2001 From: yiguolei Date: Fri, 12 Jan 2024 14:37:20 +0800 Subject: [PATCH] [chore](removelogs) remove debug query timeout logs --- be/src/vec/exec/scan/pip_scanner_context.h | 8 ++++---- be/src/vec/exec/scan/scanner_context.cpp | 2 +- be/src/vec/exec/scan/scanner_scheduler.cpp | 12 ++++++------ be/src/vec/exec/scan/vscan_node.cpp | 12 ++++++------ 4 files changed, 17 insertions(+), 17 deletions(-) diff --git a/be/src/vec/exec/scan/pip_scanner_context.h b/be/src/vec/exec/scan/pip_scanner_context.h index 8f79e3021a..404c670746 100644 --- a/be/src/vec/exec/scan/pip_scanner_context.h +++ b/be/src/vec/exec/scan/pip_scanner_context.h @@ -48,7 +48,7 @@ public: } if (!status().ok()) { - LOG(INFO) << "yyyy status not ok " << debug_string(); + //LOG(INFO) << "yyyy status not ok " << debug_string(); return _process_status; } } @@ -61,12 +61,12 @@ public: // if done, then eos is returned to indicate that the scan operator finished. if (_blocks_queues[id].empty()) { *eos = done(); - LOG(INFO) << "yyyy queue is empty and ctx finished " << debug_string(); + //LOG(INFO) << "yyyy queue is empty and ctx finished " << debug_string(); return Status::OK(); } if (_process_status.is()) { *eos = true; - LOG(INFO) << "yyyy process status is cancelled " << debug_string(); + //LOG(INFO) << "yyyy process status is cancelled " << debug_string(); return Status::OK(); } *block = std::move(_blocks_queues[id].front()); @@ -85,7 +85,7 @@ public: } if (_blocks_queues[id].empty()) { - LOG(INFO) << "yyyy block queue is empty, try to resched ctx " << debug_string(); + //LOG(INFO) << "yyyy block queue is empty, try to resched ctx " << debug_string(); this->reschedule_scanner_ctx(); } } diff --git a/be/src/vec/exec/scan/scanner_context.cpp b/be/src/vec/exec/scan/scanner_context.cpp index 046f28ae82..46650b7b13 100644 --- a/be/src/vec/exec/scan/scanner_context.cpp +++ b/be/src/vec/exec/scan/scanner_context.cpp @@ -505,7 +505,7 @@ void ScannerContext::push_back_scanner_and_reschedule(std::shared_ptr ctx) { - LOG(INFO) << "yyyy submit scanner ctx " << ctx->debug_string(); + //LOG(INFO) << "yyyy submit scanner ctx " << ctx->debug_string(); if (ctx->done()) { - LOG(INFO) << "yyyy ctx is done, not submit" << ctx->debug_string(); + //LOG(INFO) << "yyyy ctx is done, not submit" << ctx->debug_string(); return Status::EndOfFile("ScannerContext is done"); } //LOG(WARNING) << "yyyy " << Status::InternalError("Too many scheduled"); //LOG(WARNING) << "yyyy " << ctx->debug_string(); ctx->queue_idx = (_queue_idx++ % QUEUE_NUM); if (!_pending_queues[ctx->queue_idx]->blocking_put(ctx)) { - LOG(INFO) << "yyyy put to queue failed, not submit" << ctx->debug_string(); + //LOG(INFO) << "yyyy put to queue failed, not submit" << ctx->debug_string(); return Status::InternalError("failed to submit scanner context to scheduler"); } return Status::OK(); @@ -183,21 +183,21 @@ void ScannerScheduler::_schedule_scanners(std::shared_ptr ctx) { << " maybe finished"; return; } - LOG(INFO) << "yyyy scheduled, query " << ctx->debug_string(); + //LOG(INFO) << "yyyy scheduled, query " << ctx->debug_string(); MonotonicStopWatch watch; watch.reset(); watch.start(); ctx->incr_num_ctx_scheduling(1); if (ctx->done()) { - LOG(INFO) << "yyyy ctx done, " << ctx->debug_string(); + //LOG(INFO) << "yyyy ctx done, " << ctx->debug_string(); return; } std::list> this_run; ctx->get_next_batch_of_scanners(&this_run); if (this_run.empty()) { - LOG(INFO) << "yyyy run is empty, skip, " << ctx->debug_string(); + //LOG(INFO) << "yyyy run is empty, skip, " << ctx->debug_string(); // There will be 2 cases when this_run is empty: // 1. The blocks queue reaches limit. // The consumer will continue scheduling the ctx. diff --git a/be/src/vec/exec/scan/vscan_node.cpp b/be/src/vec/exec/scan/vscan_node.cpp index cf52341b34..a4c4df655a 100644 --- a/be/src/vec/exec/scan/vscan_node.cpp +++ b/be/src/vec/exec/scan/vscan_node.cpp @@ -197,13 +197,13 @@ Status VScanNode::alloc_resource(RuntimeState* state) { if (_scanner_ctx) { DCHECK(!_eos && _num_scanners->value() > 0); RETURN_IF_ERROR(_scanner_ctx->init()); - LOG(INFO) << "yyyy instance " << print_id(state->fragment_instance_id()) - << " submit scanner ctx " << _scanner_ctx->debug_string(); + //LOG(INFO) << "yyyy instance " << print_id(state->fragment_instance_id()) + // << " submit scanner ctx " << _scanner_ctx->debug_string(); RETURN_IF_ERROR(_state->exec_env()->scanner_scheduler()->submit(_scanner_ctx)); } if (_shared_scan_opt) { - LOG(INFO) << "instance shared scan enabled" - << print_id(state->fragment_instance_id()); + //LOG(INFO) << "instance shared scan enabled" + // << print_id(state->fragment_instance_id()); _shared_scanner_controller->set_scanner_context(id(), _eos ? nullptr : _scanner_ctx); } @@ -222,8 +222,8 @@ Status VScanNode::alloc_resource(RuntimeState* state) { if (_scanner_ctx) { RETURN_IF_ERROR(_scanner_ctx->init()); - LOG(INFO) << "yyyy instance " << print_id(state->fragment_instance_id()) - << " submit scanner ctx " << _scanner_ctx->debug_string(); + //LOG(INFO) << "yyyy instance " << print_id(state->fragment_instance_id()) + // << " submit scanner ctx " << _scanner_ctx->debug_string(); RETURN_IF_ERROR(_state->exec_env()->scanner_scheduler()->submit(_scanner_ctx)); } }