fix

Author: zcoo

fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorEventProcessor.java

@@ -65,8 +65,8 @@
 import org.apache.fluss.server.coordinator.event.NewTabletServerEvent;
 import org.apache.fluss.server.coordinator.event.NotifyKvSnapshotOffsetEvent;
 import org.apache.fluss.server.coordinator.event.NotifyLeaderAndIsrResponseReceivedEvent;
-import org.apache.fluss.server.coordinator.event.watcher.CoordinatorServerChangeWatcher;
 import org.apache.fluss.server.coordinator.event.SchemaChangeEvent;
+import org.apache.fluss.server.coordinator.event.watcher.CoordinatorServerChangeWatcher;
 import org.apache.fluss.server.coordinator.event.watcher.TableChangeWatcher;
 import org.apache.fluss.server.coordinator.event.watcher.TabletServerChangeWatcher;
 import org.apache.fluss.server.coordinator.statemachine.ReplicaState;

fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorLeaderElection.java

@@ -100,7 +100,6 @@ public void notLeader() {
             // Later we can make it as a hot backup server to continuously synchronize metadata from
             // Zookeeper, which save time from initializing context
             //            leaderLatch.await();
-            //            initLeaderServices.run();
 
         } catch (Exception e) {
             LOG.error("Failed to start LeaderLatch for server {}", serverId, e);

fluss-server/src/test/java/org/apache/fluss/server/coordinator/CoordinatorServerTest.java

@@ -80,5 +80,12 @@ public void waitUntilCoordinatorServerElected() {
                 () -> zookeeperClient.getCoordinatorLeaderAddress().isPresent(),
                 Duration.ofSeconds(10),
                 "Fail to wait coordinator server elected");
+        // Sleep 1 second to make sure coordinator server has been started and event processor
+        // started.
+        try {
+            Thread.sleep(1000);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
     }
 }

fluss-server/src/test/java/org/apache/fluss/server/testutils/FlussClusterExtension.java

@@ -869,6 +869,13 @@ public void waitUntilCoordinatorServerElected() {
                 () -> zooKeeperClient.getCoordinatorLeaderAddress().isPresent(),
                 Duration.ofSeconds(10),
                 "Fail to wait coordinator server elected");
+        // Sleep 1 second to make sure coordinator server has been started and event processor
+        // started.
+        try {
+            Thread.sleep(1000);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
     }
 
     // --------------------------------------------------------------------------------------------