From 135df4e5969a46b57120995b8d53b4410149cb39 Mon Sep 17 00:00:00 2001 From: hemanthsavasere Date: Fri, 13 Mar 2026 15:22:22 +0000 Subject: [PATCH] Changes to add waitUntilTableReady fixing the unstable test --- .../fluss/client/security/acl/FlussAuthorizationITCase.java | 2 ++ 1 file changed, 2 insertions(+) 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