From 29d21a1fb8394812afae98b571e29981b7484fae Mon Sep 17 00:00:00 2001
From: bharathreddygunapati <bharatgunapati@gmail.com>
Date: Wed, 12 Aug 2026 00:16:33 +0530
Subject: [PATCH] [FLUSS-3878] Fix unstable table registration watcher test

---
 .../coordinator/event/watcher/TableChangeWatcherTest.java   | 6 ++++++
 1 file changed, 6 insertions(+)

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));