mirror of
https://github.com/apache/lucene.git
synced 2025-02-23 10:51:29 +00:00
LUCENE-3985: missed updating test file
git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1369241 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
120a816d0c
commit
854eabc534
@ -905,11 +905,15 @@ public class OverseerTest extends SolrTestCaseJ4 {
|
||||
|
||||
|
||||
private SolrZkClient electNewOverseer(String address) throws InterruptedException,
|
||||
TimeoutException, IOException, KeeperException, ParserConfigurationException, SAXException {
|
||||
SolrZkClient zkClient = new SolrZkClient(address, TIMEOUT);
|
||||
TimeoutException, IOException,
|
||||
KeeperException, ParserConfigurationException, SAXException {
|
||||
SolrZkClient zkClient = new SolrZkClient(address, TIMEOUT);
|
||||
ZkStateReader reader = new ZkStateReader(zkClient);
|
||||
LeaderElector overseerElector = new LeaderElector(zkClient);
|
||||
ElectionContext ec = new OverseerElectionContext(new HttpShardHandlerFactory().getShardHandler(), "/admin/cores", address.replaceAll("/", "_"), reader);
|
||||
// TODO: close Overseer
|
||||
Overseer overseer = new Overseer(
|
||||
new HttpShardHandlerFactory().getShardHandler(), "/admin/cores", reader);
|
||||
ElectionContext ec = new OverseerElectionContext(zkClient, overseer, address.replaceAll("/", "_"));
|
||||
overseerElector.setup(ec);
|
||||
overseerElector.joinElection(ec);
|
||||
return zkClient;
|
||||
|
Loading…
x
Reference in New Issue
Block a user