Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
xyuanlu committed Jun 24, 2024
1 parent 3726ed0 commit ec051ea
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -666,7 +666,7 @@ public void handleSessionEstablishmentError(Throwable error) throws Exception {
}

@VisibleForTesting
ZkClient getZkClient() {
ZkClient getZkClient() {
return _zkClient;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -25,11 +25,8 @@ public class TestLeaderElection extends ZkMetaClientTestBase {

public static LeaderElectionClient createLeaderElectionClient(String participantName) {
MetaClientConfig.StoreType storeType = MetaClientConfig.StoreType.ZOOKEEPER;
MetaClientConfig config = new MetaClientConfig.MetaClientConfigBuilder<>().setConnectionAddress(ZK_ADDR)
.setStoreType(storeType)
.setSessionTimeoutInMillis(1 * 60 * 1000)
.setConnectionInitTimeoutInMillis(1 * 60 * 1000)
.build();
MetaClientConfig config =
new MetaClientConfig.MetaClientConfigBuilder<>().setConnectionAddress(ZK_ADDR).setStoreType(storeType).build();
return new LeaderElectionClient(config, participantName);
}

Expand Down

0 comments on commit ec051ea

Please sign in to comment.