mirror of https://github.com/apache/lucene.git
SOLR-5321: Remove unnecessary code in Overseer.updateState method which tries to use router name from message where none is ever sent
git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1530555 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
ac6633d1f3
commit
cd6c2268da
|
@ -147,6 +147,9 @@ Other Changes
|
||||||
* SOLR-5319: Remove unused and incorrect router name from Collection ZK nodes.
|
* SOLR-5319: Remove unused and incorrect router name from Collection ZK nodes.
|
||||||
(Jessica Cheng via shalin)
|
(Jessica Cheng via shalin)
|
||||||
|
|
||||||
|
* SOLR-5321: Remove unnecessary code in Overseer.updateState method which tries to
|
||||||
|
use router name from message where none is ever sent. (shalin)
|
||||||
|
|
||||||
================== 4.5.0 ==================
|
================== 4.5.0 ==================
|
||||||
|
|
||||||
Versions of Major Components
|
Versions of Major Components
|
||||||
|
|
|
@ -308,18 +308,12 @@ public class Overseer {
|
||||||
Integer numShards = message.getInt(ZkStateReader.NUM_SHARDS_PROP, null);
|
Integer numShards = message.getInt(ZkStateReader.NUM_SHARDS_PROP, null);
|
||||||
log.info("Update state numShards={} message={}", numShards, message);
|
log.info("Update state numShards={} message={}", numShards, message);
|
||||||
|
|
||||||
String router = message.getStr(OverseerCollectionProcessor.ROUTER,DocRouter.DEFAULT_NAME);
|
|
||||||
List<String> shardNames = new ArrayList<String>();
|
List<String> shardNames = new ArrayList<String>();
|
||||||
|
|
||||||
//collection does not yet exist, create placeholders if num shards is specified
|
//collection does not yet exist, create placeholders if num shards is specified
|
||||||
boolean collectionExists = state.getCollections().contains(collection);
|
boolean collectionExists = state.getCollections().contains(collection);
|
||||||
if (!collectionExists && numShards!=null) {
|
if (!collectionExists && numShards!=null) {
|
||||||
if(ImplicitDocRouter.NAME.equals(router)){
|
getShardNames(numShards, shardNames);
|
||||||
getShardNames(shardNames, message.getStr("shards",null));
|
|
||||||
numShards = shardNames.size();
|
|
||||||
}else {
|
|
||||||
getShardNames(numShards, shardNames);
|
|
||||||
}
|
|
||||||
state = createCollection(state, collection, shardNames, message);
|
state = createCollection(state, collection, shardNames, message);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue