database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[chore](removelogs) remove debug query timeout logs

Browse Source
This commit is contained in:
yiguolei
2024-01-12 14:37:20 +08:00
parent 62064a86bf
commit e4e57e9b05
4 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
be/src/vec/exec/scan/pip_scanner_context.h
View File

@ -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<ErrorCode::CANCELLED>()) {
*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();
}
}

2
be/src/vec/exec/scan/scanner_context.cpp
View File

@ -505,7 +505,7 @@ void ScannerContext::push_back_scanner_and_reschedule(std::shared_ptr<ScannerDel
set_status_on_error(submit_status, false);
}
} else {
LOG(INFO) << "yyyy should be sched == false, not sched" << debug_string();
//LOG(INFO) << "yyyy should be sched == false, not sched" << debug_string();
}
}

12
be/src/vec/exec/scan/scanner_scheduler.cpp
View File

@ -140,16 +140,16 @@ Status ScannerScheduler::init(ExecEnv* env) {
}
Status ScannerScheduler::submit(std::shared_ptr<ScannerContext> 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<ScannerContext> 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<std::weak_ptr<ScannerDelegate>> 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.

12
be/src/vec/exec/scan/vscan_node.cpp
View File

@ -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));
}
}