f

apache · Dec 28, 2024 · 39e975b · 39e975b
1 parent df86516
commit 39e975b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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<ClusterInfo>());
-        //_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;
     }