f

apache · Dec 28, 2024 · a75e268 · a75e268
1 parent 1e38e9f
commit a75e268
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,7 +60,7 @@ class RoutineLoadTaskExecutorTest : public testing::Test {
 
         _env->set_cluster_info(new ClusterInfo());
         _env->set_new_load_stream_mgr(NewLoadStreamMgr::create_unique());
-        _env->set_stream_load_executor(StreamLoadExecutor::create_unique(&_env));
+        _env->set_stream_load_executor(StreamLoadExecutor::create_unique(_env));
 
         config::max_routine_load_thread_pool_size = 1024;
         config::max_consumer_num_per_group = 3;
@@ -96,7 +96,7 @@ TEST_F(RoutineLoadTaskExecutorTest, exec_task) {
 
     task.__set_kafka_load_info(k_info);
 
-    RoutineLoadTaskExecutor executor(&_env);
+    RoutineLoadTaskExecutor executor(_env);
     Status st;
     st = executor.init(1024 * 1024);
     EXPECT_TRUE(st.ok());