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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
