增加认证相关注释
This commit is contained in:
parent
3b1b53b1ca
commit
4e06ce7167
@ -372,6 +372,7 @@ private void initZK() throws HadoopIllegalArgumentException, IOException,
|
|||||||
int maxRetryNum = conf.getInt(
|
int maxRetryNum = conf.getInt(
|
||||||
CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_KEY,
|
CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_KEY,
|
||||||
CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
|
CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
|
||||||
|
// 初始化主备选举对象。
|
||||||
elector = new ActiveStandbyElector(zkQuorum,
|
elector = new ActiveStandbyElector(zkQuorum,
|
||||||
zkTimeout, getParentZnode(), zkAcls, zkAuths,
|
zkTimeout, getParentZnode(), zkAcls, zkAuths,
|
||||||
new ElectorCallbacks(), maxRetryNum);
|
new ElectorCallbacks(), maxRetryNum);
|
||||||
|
Loading…
Reference in New Issue
Block a user