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 0b0a1b1daa5..8afe657b9cf 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
@@ -424,6 +424,12 @@ void testTableRegistrationChange() {
         // verify TableRegistrationChangeEvent is generated
         expectedEvents.add(new TableRegistrationChangeEvent(tablePath, updatedTableRegistration));
 
+        retry(
+                Duration.ofMinutes(1),
+                () ->
+                        assertThat(eventManager.getEvents())
+                                .containsExactlyInAnyOrderElementsOf(expectedEvents));
+
         metadataManager.dropTable(tablePath, false);
         expectedEvents.add(new DropTableEvent(tableId, false, false));