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 144e2ff776..6770c0d114 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 @@ -420,6 +420,10 @@ void testDescribeTableOperation() throws Exception { // 6. getLatestLakeSnapshot // 7. listOffsets + TableInfo tableInfo = rootAdmin.getTableInfo(DATA1_TABLE_PATH_PK).get(); + FLUSS_CLUSTER_EXTENSION.waitUntilAllReplicaReady( + new TableBucket(tableInfo.getTableId(), 0)); + // first check call these methods without authorization. assertThat(guestAdmin.listTables(DATA1_TABLE_PATH_PK.getDatabaseName()).get()) .isEqualTo(Collections.emptyList());