diff --git a/fluss-client/src/test/java/org/apache/fluss/client/security/acl/FlussAuthorizationITCase.java b/fluss-client/src/test/java/org/apache/fluss/client/security/acl/FlussAuthorizationITCase.java index 8c301c89a2..aaa60a45c4 100644 --- a/fluss-client/src/test/java/org/apache/fluss/client/security/acl/FlussAuthorizationITCase.java +++ b/fluss-client/src/test/java/org/apache/fluss/client/security/acl/FlussAuthorizationITCase.java @@ -150,6 +150,8 @@ protected void setup() throws Exception { DATA1_TABLE_PATH_PK.getDatabaseName(), DatabaseDescriptor.EMPTY, true) .get(); rootAdmin.createTable(DATA1_TABLE_PATH_PK, DATA1_TABLE_DESCRIPTOR_PK, true).get(); + TableInfo setupTableInfo = rootAdmin.getTableInfo(DATA1_TABLE_PATH_PK).get(); + FLUSS_CLUSTER_EXTENSION.waitUntilTableReady(setupTableInfo.getTableId()); } @AfterEach