Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix my new log line 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1346913 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Mark Robert Miller 2012-06-06 14:25:19 +00:00
parent f2765722fa
commit 21cbb77e90
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java
View File

@ -44,13 +44,16 @@ import org.apache.solr.common.params.ModifiableSolrParams;
import org.apache.solr.common.util.NamedList; import org.apache.solr.common.util.NamedList;
import org.apache.solr.core.SolrCore; import org.apache.solr.core.SolrCore;
import org.apache.solr.util.DefaultSolrThreadFactory; import org.apache.solr.util.DefaultSolrThreadFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class SolrCmdDistributor { public class SolrCmdDistributor {
private static final int MAX_RETRIES_ON_FORWARD = 6; private static final int MAX_RETRIES_ON_FORWARD = 6;
public static Logger log = LoggerFactory.getLogger(SolrCmdDistributor.class);
// TODO: shut this thing down // TODO: shut this thing down
// TODO: this cannot be per instance... // TODO: this cannot be per instance...
static ThreadPoolExecutor commExecutor = new ThreadPoolExecutor(0, static ThreadPoolExecutor commExecutor = new ThreadPoolExecutor(0,
@ -357,7 +360,7 @@ public class SolrCmdDistributor {
sreq.retries++; sreq.retries++;
sreq.rspCode = 0; sreq.rspCode = 0;
sreq.exception = null; sreq.exception = null;
SolrException.log(SolrCore.log, "forwarding update to " + sreq.node.getUrl() + " failed - retrying ... ", sreq.exception); SolrException.log(SolrCmdDistributor.log, "forwarding update to " + sreq.node.getUrl() + " failed - retrying ... ");
Thread.sleep(500); Thread.sleep(500);
submit(sreq); submit(sreq);
checkResponses(block); checkResponses(block);
@ -368,7 +371,7 @@ public class SolrCmdDistributor {
error.node = sreq.node; error.node = sreq.node;
response.errors.add(error); response.errors.add(error);
response.sreq = sreq; response.sreq = sreq;
SolrException.log(SolrCore.log, "shard update error " SolrException.log(SolrCmdDistributor.log, "shard update error "
+ sreq.node, sreq.exception); + sreq.node, sreq.exception);
} }
} }