Skip to content

Commit e7c966c

Browse files
authored
[fix](resource) Fix register ResourceContext to RuntimeQueryStatisticsMgr (apache#48004)
### What problem does this PR solve? Wait for QueryTaskController to be initialized before register ResourceContext fix ``` /root/doris/be/src/runtime/workload_management/task_controller.h:59:44: runtime error: load of value 3200171710, which is not a valid value for type 'TQueryType::type' #0 0x555ff9336162 in doris::TaskController::query_type() /root/doris/be/src/runtime/workload_management/task_controller.h:59:44 #1 0x555ff9336162 in doris::RuntimeQueryStatisticsMgr::report_runtime_query_statistics() /root/doris/be/src/runtime/runtime_query_statistics_mgr.cpp:346:50 apache#2 0x555ff50d789d in doris::Daemon::report_runtime_query_statistics_thread() /root/doris/be/src/common/daemon.cpp:487:65 apache#3 0x555ff9a3efae in std::function<void ()>::operator()() const /var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:560:9 apache#4 0x555ff9a3efae in doris::Thread::supervise_thread(void*) /root/doris/be/src/util/thread.cpp:498:5 apache#5 0x7f4935d00608 in start_thread /build/glibc-SzIz7B/glibc-2.31/nptl/pthread_create.c:477:8 apache#6 0x7f4935fad132 in __clone /build/glibc-SzIz7B/glibc-2.31/misc/../sysdeps/unix/sysv/linux/x86_64/clone.S:95 ```
1 parent 40d5653 commit e7c966c

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

be/src/runtime/query_context.cpp

+4-4
Original file line numberDiff line numberDiff line change
@@ -181,17 +181,17 @@ void QueryContext::_init_resource_context() {
181181
_resource_ctx = ResourceContext::create_shared();
182182
_resource_ctx->set_memory_context(QueryContext::QueryMemoryContext::create());
183183
_init_query_mem_tracker();
184-
#ifndef BE_TEST
185-
_exec_env->runtime_query_statistics_mgr()->register_resource_context(print_id(_query_id),
186-
_resource_ctx);
187-
#endif
188184
}
189185

190186
void QueryContext::init_query_task_controller() {
191187
_resource_ctx->set_task_controller(QueryContext::QueryTaskController::create(this));
192188
_resource_ctx->task_controller()->set_task_id(_query_id);
193189
_resource_ctx->task_controller()->set_fe_addr(current_connect_fe);
194190
_resource_ctx->task_controller()->set_query_type(_query_options.query_type);
191+
#ifndef BE_TEST
192+
_exec_env->runtime_query_statistics_mgr()->register_resource_context(print_id(_query_id),
193+
_resource_ctx);
194+
#endif
195195
}
196196

197197
QueryContext::~QueryContext() {

0 commit comments

Comments
 (0)