Fix config for metaclient leader election client. (#2807)

apache · Jun 11, 2024 · 55bdc08 · 55bdc08
1 parent b7d771e
commit 55bdc08
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...rc/main/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderElectionClient.java b/...rc/main/java/org/apache/helix/metaclient/recipes/leaderelection/LeaderElectionClient.java
@@ -97,7 +97,13 @@ public LeaderElectionClient(MetaClientConfig metaClientConfig, String participan
     LOG.info("Creating MetaClient for LeaderElectionClient");
     if (MetaClientConfig.StoreType.ZOOKEEPER.equals(metaClientConfig.getStoreType())) {
       ZkMetaClientConfig zkMetaClientConfig = new ZkMetaClientConfig.ZkMetaClientConfigBuilder().setConnectionAddress(
-          metaClientConfig.getConnectionAddress()).setZkSerializer((new LeaderInfoSerializer())).build();
+              metaClientConfig.getConnectionAddress())
+          .setZkSerializer((new LeaderInfoSerializer()))
+          .setSessionTimeoutInMillis(metaClientConfig.getSessionTimeoutInMillis())
+          .setMetaClientReconnectPolicy(metaClientConfig.getMetaClientReconnectPolicy())
+          .setConnectionInitTimeoutInMillis(metaClientConfig.getConnectionInitTimeoutInMillis())
+          .setAuthEnabled(metaClientConfig.isAuthEnabled())
+          .build();
       _metaClient = new ZkMetaClientFactory().getMetaClient(zkMetaClientConfig);
       _metaClient.connect();
       _metaClient.subscribeStateChanges(_connectStateListener);