From 39e975b3abc3be5e545f224bf2cb1c9fbbc407c1 Mon Sep 17 00:00:00 2001 From: yiguolei Date: Sat, 28 Dec 2024 13:34:31 +0800 Subject: [PATCH] f --- be/test/runtime/routine_load_task_executor_test.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/be/test/runtime/routine_load_task_executor_test.cpp b/be/test/runtime/routine_load_task_executor_test.cpp index ea6d3c5e3bc64a6..0fdcab6ed57b1a2 100644 --- a/be/test/runtime/routine_load_task_executor_test.cpp +++ b/be/test/runtime/routine_load_task_executor_test.cpp @@ -60,9 +60,9 @@ class RoutineLoadTaskExecutorTest : public testing::Test { k_stream_load_put_result = TStreamLoadPutResult(); _env->set_cluster_info(std::make_unique()); - //_env->set_new_load_stream_mgr(NewLoadStreamMgr::create_unique()); + _env->set_new_load_stream_mgr(NewLoadStreamMgr::create_unique()); _env->set_stream_load_executor(StreamLoadExecutor::create_unique(_env)); - + _env->set_ready(); config::max_routine_load_thread_pool_size = 1024; config::max_consumer_num_per_group = 3; }