[pinot] branch master updated: Move HelixManager initialization to init (#7666)

[nehapawar]

This is an automated email from the ASF dual-hosted git repository.

nehapawar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git


The following commit(s) were added to refs/heads/master by this push:
     new e814203  Move HelixManager initialization to init (#7666)
e814203 is described below

commit e814203c24c860edef8277aee50e54ff8d86d042
Author: Neha Pawar <neha.pawa...@gmail.com>
AuthorDate: Fri Oct 29 17:51:20 2021 -0700

    Move HelixManager initialization to init (#7666)
---
 .../apache/pinot/server/starter/helix/BaseServerStarter.java   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/pinot-server/src/main/java/org/apache/pinot/server/starter/helix/BaseServerStarter.java
 
b/pinot-server/src/main/java/org/apache/pinot/server/starter/helix/BaseServerStarter.java
index 92c315b..3686679 100644
--- 
a/pinot-server/src/main/java/org/apache/pinot/server/starter/helix/BaseServerStarter.java
+++ 
b/pinot-server/src/main/java/org/apache/pinot/server/starter/helix/BaseServerStarter.java
@@ -176,6 +176,11 @@ public abstract class BaseServerStarter implements 
ServiceStartable {
     // Set data table version send to broker.
     DataTableBuilder.setCurrentDataTableVersion(_serverConf
         .getProperty(Server.CONFIG_OF_CURRENT_DATA_TABLE_VERSION, 
Server.DEFAULT_CURRENT_DATA_TABLE_VERSION));
+
+    LOGGER.info("Initializing Helix manager with zkAddress: {}, clusterName: 
{}, instanceId: {}", _zkAddress,
+        _helixClusterName, _instanceId);
+    _helixManager =
+        HelixManagerFactory.getZKHelixManager(_helixClusterName, _instanceId, 
InstanceType.PARTICIPANT, _zkAddress);
   }
 
   /**
@@ -369,11 +374,6 @@ public abstract class BaseServerStarter implements 
ServiceStartable {
       TlsUtils.installDefaultSSLSocketFactory(tlsDefaults);
     }
 
-    LOGGER.info("Initializing Helix manager with zkAddress: {}, clusterName: 
{}, instanceId: {}", _zkAddress,
-        _helixClusterName, _instanceId);
-    _helixManager =
-        HelixManagerFactory.getZKHelixManager(_helixClusterName, _instanceId, 
InstanceType.PARTICIPANT, _zkAddress);
-
     LOGGER.info("Initializing server instance and registering state model 
factory");
     Utils.logVersions();
     ControllerLeaderLocator.create(_helixManager);

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org