You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by ho...@apache.org on 2023/01/07 00:54:12 UTC

[solr] 03/12: Fix root cause of bug

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

hossman pushed a commit to branch jira/SOLR-6312
in repository https://gitbox.apache.org/repos/asf/solr.git

commit cb52dd264e51d263b30f95802237521e088c7ebd
Author: Chris Hostetter <ho...@apache.org>
AuthorDate: Fri Dec 16 16:09:08 2022 -0700

    Fix root cause of bug
---
 .../java/org/apache/solr/client/solrj/impl/CloudSolrClient.java   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/CloudSolrClient.java b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/CloudSolrClient.java
index b435ef72233..56a9c4e14c4 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/CloudSolrClient.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/CloudSolrClient.java
@@ -1046,7 +1046,12 @@ public abstract class CloudSolrClient extends SolrClient {
     boolean isUpdate = false;
 
     if (request instanceof IsUpdateRequest) {
-      if (request instanceof UpdateRequest) {
+      sendToLeaders =
+          // nocommit: also check request.isSendToLeaders() (still to be added)
+          this.isUpdatesToLeaders();
+
+      // Check if we can do a "directUpdate" ...
+      if (sendToLeaders && request instanceof UpdateRequest) {
         isUpdate = true;
         if (inputCollections.size() > 1) {
           throw new SolrException(
@@ -1064,7 +1069,6 @@ public abstract class CloudSolrClient extends SolrClient {
           return response;
         }
       }
-      sendToLeaders = true;
     }
 
     SolrParams reqParams = request.getParams();