Skip to content

Commit f2e5d08

Browse files
committed
support coordinator epoch2
1 parent 8c1940a commit f2e5d08

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -237,8 +237,6 @@ protected void startCoordinatorLeaderService() throws Exception {
237237
serverMetricGroup));
238238
rpcServer.start();
239239

240-
registerCoordinatorLeader();
241-
242240
this.clientMetricGroup = new ClientMetricGroup(metricRegistry, SERVER_NAME);
243241
this.rpcClient = RpcClient.create(conf, clientMetricGroup, true);
244242

@@ -253,6 +251,7 @@ protected void startCoordinatorLeaderService() throws Exception {
253251
Executors.newFixedThreadPool(
254252
ioExecutorPoolSize, new ExecutorThreadFactory("coordinator-io"));
255253

254+
registerCoordinatorLeader();
256255
// start coordinator event processor after we register coordinator leader to zk
257256
// so that the event processor can get the coordinator leader node from zk during start
258257
// up.

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -274,6 +274,7 @@ public void startCoordinatorServer() throws Exception {
274274
} else {
275275
// start the existing coordinator server
276276
coordinatorServer.start();
277+
waitUntilCoordinatorServerElected();
277278
coordinatorServerInfo =
278279
new ServerInfo(
279280
0,

0 commit comments

Comments
 (0)