(fluss) branch main updated: [tests] Cleanup ZK state in TableChangeWatcherTest to not let current tests be impacted by leftover events from previous tests. (#2249)

[hongshun]

This is an automated email from the ASF dual-hosted git repository.

hongshun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new a8308b548 [tests] Cleanup ZK state in TableChangeWatcherTest to not 
let current tests be impacted by leftover events from previous tests. (#2249)
a8308b548 is described below

commit a8308b548defdb3296b9d46a1f7faf7a10e6482e
Author: vamossagar12 <sagar...@google.com>
AuthorDate: Mon Jan 19 07:54:23 2026 +0530

    [tests] Cleanup ZK state in TableChangeWatcherTest to not let current tests 
be impacted by leftover events from previous tests. (#2249)
---
 .../server/coordinator/event/watcher/TableChangeWatcherTest.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/fluss-server/src/test/java/org/apache/fluss/server/coordinator/event/watcher/TableChangeWatcherTest.java
 
b/fluss-server/src/test/java/org/apache/fluss/server/coordinator/event/watcher/TableChangeWatcherTest.java
index bb9a25d1d..691f0d9ce 100644
--- 
a/fluss-server/src/test/java/org/apache/fluss/server/coordinator/event/watcher/TableChangeWatcherTest.java
+++ 
b/fluss-server/src/test/java/org/apache/fluss/server/coordinator/event/watcher/TableChangeWatcherTest.java
@@ -91,11 +91,18 @@ class TableChangeWatcherTest {
                         zookeeperClient,
                         new Configuration(),
                         new LakeCatalogDynamicLoader(new Configuration(), 
null, true));
-        metadataManager.createDatabase(DEFAULT_DB, 
DatabaseDescriptor.builder().build(), false);
     }
 
     @BeforeEach
     void before() {
+        // Clean up ZK state from previous tests to prevent CuratorCache 
initial sync
+        // from picking up leftover data
+        try {
+            metadataManager.dropDatabase(DEFAULT_DB, true, true);
+        } catch (Exception ignored) {
+        }
+        metadataManager.createDatabase(DEFAULT_DB, 
DatabaseDescriptor.builder().build(), false);
+
         eventManager = new TestingEventManager();
         tableChangeWatcher = new TableChangeWatcher(zookeeperClient, 
eventManager);
         tableChangeWatcher.start();