Skip to content

Commit

Permalink
f
Browse files Browse the repository at this point in the history
  • Loading branch information
yiguolei committed Dec 27, 2024
1 parent aa5592d commit 442a274
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion be/test/olap/wal/wal_manager_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ class WalManagerTest : public testing::Test {
_env->_cluster_info->master_fe_addr.hostname = "host name";
_env->_cluster_info->master_fe_addr.port = 1234;
_env->_cluster_info->backend_id = 1001;
_env->set_new_load_stream_mgr(NewLoadStreamMgr::create_unique());
// _env->set_new_load_stream_mgr(NewLoadStreamMgr::create_unique());
_env->_internal_client_cache = new BrpcClientCache<PBackendService_Stub>();
_env->_function_client_cache = new BrpcClientCache<PFunctionService_Stub>();
_env->_stream_load_executor = StreamLoadExecutor::create_unique(_env);
Expand Down
2 changes: 1 addition & 1 deletion be/test/runtime/routine_load_task_executor_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ class RoutineLoadTaskExecutorTest : public testing::Test {
k_stream_load_put_result = TStreamLoadPutResult();

_env.set_cluster_info(new 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));

config::max_routine_load_thread_pool_size = 1024;
Expand Down

0 comments on commit 442a274

Please sign in to comment.