From 9ffa377c517fc9f211e391f123f15be608baa97f Mon Sep 17 00:00:00 2001 From: vamossagar12 Date: Thu, 25 Dec 2025 08:42:52 +0530 Subject: [PATCH] Clearing all test events after each test --- .../server/coordinator/event/watcher/TableChangeWatcherTest.java | 1 + 1 file changed, 1 insertion(+) 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 0ed0c9d956..20ebea1f64 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 @@ -106,6 +106,7 @@ void after() { if (tableChangeWatcher != null) { tableChangeWatcher.stop(); } + eventManager.clearEvents(); } @Test