[lucene-solr] branch reference_impl updated: #73 Tweak that Overseer.

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

markrmiller pushed a commit to branch reference_impl
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git


The following commit(s) were added to refs/heads/reference_impl by this push:
     new 172e276  #73 Tweak that Overseer.
172e276 is described below

commit 172e27637a119eb048bf0649a8c9e306edf1dd53
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Sat Jul 11 15:23:31 2020 -0500

    #73 Tweak that Overseer.
---
 .../src/java/org/apache/solr/cloud/OverseerTaskProcessor.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/solr/core/src/java/org/apache/solr/cloud/OverseerTaskProcessor.java b/solr/core/src/java/org/apache/solr/cloud/OverseerTaskProcessor.java
index 8c13d30..aa80558 100644
--- a/solr/core/src/java/org/apache/solr/cloud/OverseerTaskProcessor.java
+++ b/solr/core/src/java/org/apache/solr/cloud/OverseerTaskProcessor.java
@@ -227,11 +227,11 @@ public class OverseerTaskProcessor implements Runnable, Closeable {
               if (!tooManyTasks) {
                 tooManyTasks = runningTasksSize() >= MAX_PARALLEL_TASKS;
               }
-
-              if (runningZKTasks.contains(head.getId())) {
-                log.warn("Task found in running ZKTasks already, contining");
-                continue;
-              }
+// nocommit
+//              if (runningZKTasks.contains(head.getId())) {
+//                log.warn("Task found in running ZKTasks already, contining");
+//                continue;
+//              }
 
               final ZkNodeProps message = ZkNodeProps.load(head.getBytes());
               final String asyncId = message.getStr(ASYNC);