Skip to content

Commit 7833411

Browse files
authored
[hotfix] MetadataUpdater#tryToInitializeCluster should use COORDINATOR server type (#456)
1 parent 756c3a2 commit 7833411

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

fluss-client/src/main/java/com/alibaba/fluss/client/metadata/MetadataUpdater.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -300,7 +300,7 @@ private static Cluster initializeCluster(Configuration conf, RpcClient rpcClient
300300
RpcClient rpcClient, InetSocketAddress address) {
301301
ServerNode serverNode =
302302
new ServerNode(
303-
-1, address.getHostName(), address.getPort(), ServerType.TABLET_SERVER);
303+
-1, address.getHostName(), address.getPort(), ServerType.COORDINATOR);
304304
try {
305305
AdminReadOnlyGateway adminReadOnlyGateway =
306306
GatewayClientProxy.createGatewayProxy(

0 commit comments

Comments
 (0)