Skip to content

Commit

Permalink
[BugFix] Fix information_schema.fe_locks schema table visit bug (#45927)
Browse files Browse the repository at this point in the history
Signed-off-by: shuming.li <[email protected]>
  • Loading branch information
LiShuMing authored May 21, 2024
1 parent 2bb8e40 commit a2460eb
Show file tree
Hide file tree
Showing 5 changed files with 8 additions and 4 deletions.
4 changes: 2 additions & 2 deletions be/src/exec/schema_scanner/sys_fe_locks.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down
2 changes: 1 addition & 1 deletion be/src/exec/schema_scanner/sys_fe_memory_usage.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down
2 changes: 1 addition & 1 deletion be/src/exec/schema_scanner/sys_object_dependencies.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down
2 changes: 2 additions & 0 deletions test/sql/test_sys/R/test_fe_locks
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
-- name: test_fe_locks
[UC] select count(*) > 1 from sys.fe_locks;
2 changes: 2 additions & 0 deletions test/sql/test_sys/T/test_fe_locks
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
-- name: test_fe_locks
select count(*) > 1 from sys.fe_locks;

0 comments on commit a2460eb

Please sign in to comment.