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 2012/11/20 20:04:17 UTC
svn commit: r1411801 -
/lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/Overseer.java
Author: markrmiller
Date: Tue Nov 20 19:04:17 2012
New Revision: 1411801
URL: http://svn.apache.org/viewvc?rev=1411801&view=rev
Log:
add logging around shard assignment
Modified:
lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/Overseer.java
Modified: lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/Overseer.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/Overseer.java?rev=1411801&r1=1411800&r2=1411801&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/Overseer.java (original)
+++ lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/Overseer.java Tue Nov 20 19:04:17 2012
@@ -221,14 +221,19 @@ public class Overseer {
String nodeName = message.getStr(ZkStateReader.NODE_NAME_PROP);
//get shardId from ClusterState
sliceName = getAssignedId(state, nodeName, message);
+ if (sliceName != null) {
+ log.info("shard=" + sliceName + " is already registered");
+ }
}
if(sliceName == null) {
//request new shardId
if (collectionExists) {
// use existing numShards
numShards = state.getCollectionStates().get(collection).size();
+ log.info("Collection already exists with " + ZkStateReader.NUM_SHARDS_PROP + "=" + numShards);
}
sliceName = AssignShard.assignShard(collection, state, numShards);
+ log.info("Assigning new node to shard shard=" + sliceName);
}
Slice slice = state.getSlice(collection, sliceName);