You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2017/02/22 15:24:49 UTC
[5/5] lucene-solr:branch_6x: tests: get leader to base clase
tests: get leader to base clase
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/e1ae3a8e
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/e1ae3a8e
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/e1ae3a8e
Branch: refs/heads/branch_6x
Commit: e1ae3a8ed83dfeaf3a22f2bb1e229868cadfbd62
Parents: 0b9e025
Author: markrmiller <ma...@apache.org>
Authored: Mon Dec 12 10:56:51 2016 -0500
Committer: markrmiller <ma...@apache.org>
Committed: Wed Feb 22 10:17:59 2017 -0500
----------------------------------------------------------------------
.../apache/solr/cloud/AbstractFullDistribZkTestBase.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/e1ae3a8e/solr/test-framework/src/java/org/apache/solr/cloud/AbstractFullDistribZkTestBase.java
----------------------------------------------------------------------
diff --git a/solr/test-framework/src/java/org/apache/solr/cloud/AbstractFullDistribZkTestBase.java b/solr/test-framework/src/java/org/apache/solr/cloud/AbstractFullDistribZkTestBase.java
index a7660d8..2a8d453 100644
--- a/solr/test-framework/src/java/org/apache/solr/cloud/AbstractFullDistribZkTestBase.java
+++ b/solr/test-framework/src/java/org/apache/solr/cloud/AbstractFullDistribZkTestBase.java
@@ -829,6 +829,15 @@ public abstract class AbstractFullDistribZkTestBase extends AbstractDistribZkTes
// add to control second in case adding to shards fails
controlClient.add(doc);
}
+
+ protected ZkCoreNodeProps getLeaderUrlFromZk(String collection, String slice) {
+ ClusterState clusterState = getCommonCloudSolrClient().getZkStateReader().getClusterState();
+ ZkNodeProps leader = clusterState.getLeader(collection, slice);
+ if (leader == null) {
+ throw new RuntimeException("Could not find leader:" + collection + " " + slice);
+ }
+ return new ZkCoreNodeProps(leader);
+ }
@Override
protected void del(String q) throws Exception {