CaoManhDat commented on a change in pull request #1470: URL: https://github.com/apache/lucene-solr/pull/1470#discussion_r422459139
########## File path: solr/core/src/java/org/apache/solr/handler/component/HttpShardHandler.java ########## @@ -130,77 +134,64 @@ public void submit(final ShardRequest sreq, final String shard, final Modifiable final Tracer tracer = GlobalTracer.getTracer(); final Span span = tracer != null ? tracer.activeSpan() : null; - Callable<ShardResponse> task = () -> { + params.remove(CommonParams.WT); // use default (currently javabin) + params.remove(CommonParams.VERSION); + QueryRequest req = makeQueryRequest(sreq, params, shard); + req.setMethod(SolrRequest.METHOD.POST); - ShardResponse srsp = new ShardResponse(); - if (sreq.nodeName != null) { - srsp.setNodeName(sreq.nodeName); - } - srsp.setShardRequest(sreq); - srsp.setShard(shard); - SimpleSolrResponse ssr = new SimpleSolrResponse(); - srsp.setSolrResponse(ssr); - long startTime = System.nanoTime(); + LBSolrClient.Req lbReq = httpShardHandlerFactory.newLBHttpSolrClientReq(req, urls); + + ShardResponse srsp = new ShardResponse(); + if (sreq.nodeName != null) { + srsp.setNodeName(sreq.nodeName); + } + srsp.setShardRequest(sreq); + srsp.setShard(shard); + SimpleSolrResponse ssr = new SimpleSolrResponse(); + srsp.setSolrResponse(ssr); + + pending.incrementAndGet(); + // if there are no shards available for a slice, urls.size()==0 + if (urls.size() == 0) { + // TODO: what's the right error code here? We should use the same thing when Review comment: I do not, just copied and pasted from the old code. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@lucene.apache.org For additional commands, e-mail: issues-h...@lucene.apache.org