diff --git a/be/src/exec/schema_scanner/sys_fe_locks.cpp b/be/src/exec/schema_scanner/sys_fe_locks.cpp index 68bdc9493e0af..db20d0e8ebc68 100644 --- a/be/src/exec/schema_scanner/sys_fe_locks.cpp +++ b/be/src/exec/schema_scanner/sys_fe_locks.cpp @@ -43,12 +43,12 @@ Status SysFeLocks::start(RuntimeState* state) { RETURN_IF(!_param->ip || !_param->port, Status::InternalError("IP or port not exists")); RETURN_IF_ERROR(SchemaScanner::start(state)); + RETURN_IF_ERROR(SchemaScanner::init_schema_scanner_state(state)); TAuthInfo auth = build_auth_info(); TFeLocksReq request; request.__set_auth_info(auth); - - return (SchemaHelper::list_fe_locks(_ss_state, request, &_result)); + return SchemaHelper::list_fe_locks(_ss_state, request, &_result); } Status SysFeLocks::_fill_chunk(ChunkPtr* chunk) { diff --git a/be/src/exec/schema_scanner/sys_fe_memory_usage.cpp b/be/src/exec/schema_scanner/sys_fe_memory_usage.cpp index 4ecae763e6141..f87662fa1d2d1 100644 --- a/be/src/exec/schema_scanner/sys_fe_memory_usage.cpp +++ b/be/src/exec/schema_scanner/sys_fe_memory_usage.cpp @@ -44,7 +44,7 @@ Status SysFeMemoryUsage::start(RuntimeState* state) { TFeMemoryReq request; request.__set_auth_info(auth); - return (SchemaHelper::list_fe_memory_usage(_ss_state, request, &_result)); + return SchemaHelper::list_fe_memory_usage(_ss_state, request, &_result); } Status SysFeMemoryUsage::_fill_chunk(ChunkPtr* chunk) { diff --git a/be/src/exec/schema_scanner/sys_object_dependencies.cpp b/be/src/exec/schema_scanner/sys_object_dependencies.cpp index 4be98b93f1b48..478c8a35f3041 100644 --- a/be/src/exec/schema_scanner/sys_object_dependencies.cpp +++ b/be/src/exec/schema_scanner/sys_object_dependencies.cpp @@ -52,7 +52,7 @@ Status SysObjectDependencies::start(RuntimeState* state) { TObjectDependencyReq request; request.__set_auth_info(auth); - return (SchemaHelper::list_object_dependencies(_ss_state, request, &_result)); + return SchemaHelper::list_object_dependencies(_ss_state, request, &_result); } Status SysObjectDependencies::_fill_chunk(ChunkPtr* chunk) { diff --git a/test/sql/test_sys/R/test_fe_locks b/test/sql/test_sys/R/test_fe_locks new file mode 100644 index 0000000000000..2eabd639d6a56 --- /dev/null +++ b/test/sql/test_sys/R/test_fe_locks @@ -0,0 +1,2 @@ +-- name: test_fe_locks +[UC] select count(*) > 1 from sys.fe_locks; diff --git a/test/sql/test_sys/T/test_fe_locks b/test/sql/test_sys/T/test_fe_locks new file mode 100644 index 0000000000000..b5f79602a7bda --- /dev/null +++ b/test/sql/test_sys/T/test_fe_locks @@ -0,0 +1,2 @@ +-- name: test_fe_locks +select count(*) > 1 from sys.fe_locks; \ No newline at end of file