diff --git a/fluss-client/src/test/java/org/apache/fluss/client/admin/FlussAdminITCase.java b/fluss-client/src/test/java/org/apache/fluss/client/admin/FlussAdminITCase.java index 4b1dc28ac7..84c15d5c02 100644 --- a/fluss-client/src/test/java/org/apache/fluss/client/admin/FlussAdminITCase.java +++ b/fluss-client/src/test/java/org/apache/fluss/client/admin/FlussAdminITCase.java @@ -1517,6 +1517,23 @@ void testDynamicConfigs() throws Exception { .build(), true); + waitUntil( + () -> { + // First, verify that cluster configs have been updated + Collection configEntries = admin.describeClusterConfigs().get(); + Map clusterConfigs = + configEntries.stream() + .collect( + Collectors.toMap(ConfigEntry::key, ConfigEntry::value)); + return clusterConfigs.containsKey(DATALAKE_FORMAT.key()) + && PAIMON.toString().equals(clusterConfigs.get(DATALAKE_FORMAT.key())) + && clusterConfigs.containsKey("datalake.paimon.warehouse") + && "test-warehouse" + .equals(clusterConfigs.get("datalake.paimon.warehouse")); + }, + Duration.ofMinutes(1), + "Cluster configs should be updated with datalake properties"); + waitUntil( () -> { TableInfo tableInfo = admin.getTableInfo(tablePath).get();