lucene-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From markrmil...@apache.org
Subject svn commit: r1546186 - /lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java
Date Wed, 27 Nov 2013 20:40:01 GMT
Author: markrmiller
Date: Wed Nov 27 20:40:01 2013
New Revision: 1546186

URL: http://svn.apache.org/r1546186
Log:
SOLR-5509: better debug logging

Modified:
    lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java

Modified: lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java?rev=1546186&r1=1546185&r2=1546186&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java
(original)
+++ lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java
Wed Nov 27 20:40:01 2013
@@ -579,6 +579,9 @@ public class DistributedUpdateProcessor 
       if (isLeader || isSubShardLeader) {
         params.set(DISTRIB_FROM, ZkCoreNodeProps.getCoreUrl(
             zkController.getBaseUrl(), req.getCore().getName()));
+      } else if (log.isDebugEnabled()) {
+        params.set(DISTRIB_FROM, ZkCoreNodeProps.getCoreUrl(
+            zkController.getBaseUrl(), req.getCore().getName()));
       }
 
       cmdDistrib.distribAdd(cmd, nodes, params);
@@ -1008,6 +1011,9 @@ public class DistributedUpdateProcessor 
       if (isLeader || isSubShardLeader) {
         params.set(DISTRIB_FROM, ZkCoreNodeProps.getCoreUrl(
             zkController.getBaseUrl(), req.getCore().getName()));
+      } else if (log.isDebugEnabled()) {
+        params.set(DISTRIB_FROM, ZkCoreNodeProps.getCoreUrl(
+            zkController.getBaseUrl(), req.getCore().getName()));
       }
       cmdDistrib.distribDelete(cmd, nodes, params);
     }
@@ -1069,6 +1075,10 @@ public class DistributedUpdateProcessor 
 
       ModifiableSolrParams outParams = new ModifiableSolrParams(filterParams(req.getParams()));
       outParams.set(DISTRIB_UPDATE_PARAM, DistribPhase.TOLEADER.toString());
+      if (log.isDebugEnabled()) {
+        outParams.set(DISTRIB_FROM, ZkCoreNodeProps.getCoreUrl(
+            zkController.getBaseUrl(), req.getCore().getName()));
+      }
 
       SolrParams params = req.getParams();
       String route = params.get(ShardParams._ROUTE_);



Mime
View raw message