svn commit: r1243773 - /lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/DistributedUpdateProcessor.java

[yo...@apache.org]

Author: yonik
Date: Tue Feb 14 03:00:22 2012
New Revision: 1243773

URL: http://svn.apache.org/viewvc?rev=1243773&view=rev
Log:
dbq: fix param rename

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=1243773&r1=1243772&r2=1243773&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 Tue Feb 14 03:00:22 2012
@@ -530,7 +530,7 @@ public class DistributedUpdateProcessor 
       Map<String,Slice> slices = zkController.getCloudState().getSlices(collection);
 
       ModifiableSolrParams params = new ModifiableSolrParams(req.getParams());
-      params.set("dbqlevel", 2);
+      params.set(DELETE_BY_QUERY_LEVEL, 2);
 
       List<Node> leaders =  new ArrayList<Node>(slices.size());
       for (Map.Entry<String,Slice> sliceEntry : slices.entrySet()) {
@@ -616,7 +616,7 @@ public class DistributedUpdateProcessor 
           // forward to all replicas
           if (replicas != null) {
             ModifiableSolrParams params = new ModifiableSolrParams(req.getParams());
-            params.set("dbqlevel", 3);
+            params.set(DELETE_BY_QUERY_LEVEL, 3);
             params.set(VERSION_FIELD, Long.toString(cmd.getVersion()));
             params.set(SEEN_LEADER, "true");
             cmdDistrib.distribDelete(cmd, replicas, params);