You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by da...@apache.org on 2017/10/30 03:06:12 UTC
lucene-solr:branch_7x: SOLR-11452: Leader from collectionState can be
null
Repository: lucene-solr
Updated Branches:
refs/heads/branch_7x f70205a39 -> d24cd6e73
SOLR-11452: Leader from collectionState can be null
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/d24cd6e7
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/d24cd6e7
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/d24cd6e7
Branch: refs/heads/branch_7x
Commit: d24cd6e73fde7dbfdf3f5ec99aca5c9aa3a1ee94
Parents: f70205a
Author: Cao Manh Dat <da...@apache.org>
Authored: Mon Oct 30 10:04:08 2017 +0700
Committer: Cao Manh Dat <da...@apache.org>
Committed: Mon Oct 30 10:05:59 2017 +0700
----------------------------------------------------------------------
.../core/src/test/org/apache/solr/cloud/TestTlogReplica.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/d24cd6e7/solr/core/src/test/org/apache/solr/cloud/TestTlogReplica.java
----------------------------------------------------------------------
diff --git a/solr/core/src/test/org/apache/solr/cloud/TestTlogReplica.java b/solr/core/src/test/org/apache/solr/cloud/TestTlogReplica.java
index 026bbff..51eac98 100644
--- a/solr/core/src/test/org/apache/solr/cloud/TestTlogReplica.java
+++ b/solr/core/src/test/org/apache/solr/cloud/TestTlogReplica.java
@@ -676,8 +676,12 @@ public class TestTlogReplica extends SolrCloudTestCase {
String oldLeaderNodeName = oldLeaderJetty.getNodeName();
ChaosMonkey.kill(oldLeaderJetty);
waitForState("Replica not removed", collectionName, activeReplicaCount(0, 1, 0));
- waitForState("Expect new leader", collectionName, (liveNodes, collectionState) ->
- !collectionState.getLeader("shard1").getNodeName().equals(oldLeaderNodeName)
+ waitForState("Expect new leader", collectionName,
+ (liveNodes, collectionState) -> {
+ Replica leader = collectionState.getLeader("shard1");
+ if (leader == null) return false;
+ return !leader.getNodeName().equals(oldLeaderNodeName);
+ }
);
ChaosMonkey.start(oldLeaderJetty);
waitForState("Replica not added", collectionName, activeReplicaCount(0, 2, 0));