From cc0d0e80034bcbffa7755ed817ee2dcb10b5af98 Mon Sep 17 00:00:00 2001
From: duankaixuan <1417048384@qq.com>
Date: Tue, 12 May 2026 00:35:40 +0800
Subject: [PATCH] [test] Fix flaky FlussAdminITCase.testDynamicConfigs

---
 .../fluss/client/admin/FlussAdminITCase.java    | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

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<ConfigEntry> configEntries = admin.describeClusterConfigs().get();
+                    Map<String, String> 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();