[lucene-solr] branch reference_impl updated: @652 Switch to root executor - all these stream ones need to be unlimited.

[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 0de8de2  @652 Switch to root executor - all these stream ones need to be unlimited.
0de8de2 is described below

commit 0de8de20224a4e7f02e5ae019423cff9475fd865
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Mon Aug 31 12:39:45 2020 -0500

    @652 Switch to root executor - all these stream ones need to be unlimited.
---
 .../java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java
index f6eadfa..08984ed 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java
@@ -395,7 +395,7 @@ public class CloudSolrStream extends TupleStream implements Expressible {
   }
 
   protected void openStreams() throws IOException {
-    final ExecutorService service = ParWork.getMyPerThreadExecutor();
+    final ExecutorService service = ParWork.getRootSharedExecutor();
     List<Future<TupleWrapper>> futures =
         solrStreams.stream().map(ss -> service.submit(new StreamOpener((SolrStream)ss, comp))).collect(Collectors.toList());
     try {