diff --git a/solr/core/src/java/org/apache/solr/SolrLogFormatter.java b/solr/core/src/java/org/apache/solr/SolrLogFormatter.java index 2c186873d7d..2bcd0d06582 100644 --- a/solr/core/src/java/org/apache/solr/SolrLogFormatter.java +++ b/solr/core/src/java/org/apache/solr/SolrLogFormatter.java @@ -196,12 +196,8 @@ sb.append("(group_name=").append(tg.getName()).append(")"); sb.append(" url="+info.url + " node="+zkController.getNodeName()); } - if(info.coreProps == null) { - info.coreProps = getCoreProps(zkController, core); - } - - Map coreProps = getCoreProps(zkController, core); - if(!coreProps.equals(info.coreProps)) { + Map coreProps = getReplicaProps(zkController, core); + if (info.coreProps == null || !coreProps.equals(info.coreProps)) { info.coreProps = coreProps; final String corePropsString = "coll:" + core.getCoreDescriptor().getCloudDescriptor().getCollectionName() + " core:" + core.getName() + " props:" + coreProps; sb.append(" " + info.shortId + "_STATE=" + corePropsString); @@ -261,11 +257,11 @@ sb.append("(group_name=").append(tg.getName()).append(")"); return sb.toString(); } - private Map getCoreProps(ZkController zkController, SolrCore core) { + private Map getReplicaProps(ZkController zkController, SolrCore core) { final String collection = core.getCoreDescriptor().getCloudDescriptor().getCollectionName(); - Replica props = zkController.getClusterState().getReplica(collection, ZkStateReader.getCoreNodeName(zkController.getNodeName(), core.getName())); - if(props!=null) { - return props.getProperties(); + Replica replica = zkController.getClusterState().getReplica(collection, ZkStateReader.getCoreNodeName(zkController.getNodeName(), core.getName())); + if(replica!=null) { + return replica.getProperties(); } return Collections.EMPTY_MAP; } diff --git a/solr/core/src/java/org/apache/solr/cloud/ZkController.java b/solr/core/src/java/org/apache/solr/cloud/ZkController.java index 3eedaa35e30..68fa6495741 100644 --- a/solr/core/src/java/org/apache/solr/cloud/ZkController.java +++ b/solr/core/src/java/org/apache/solr/cloud/ZkController.java @@ -628,8 +628,8 @@ public final class ZkController { if (log.isInfoEnabled()) { - log.info("Register shard - core:" + coreName + " address:" - + baseUrl + " shardId:" + shardId); + log.info("Register replica - core:" + coreName + " address:" + + baseUrl + " collection:" + cloudDesc.getCollectionName() + " shard:" + shardId); } ZkNodeProps leaderProps = new ZkNodeProps(props);