You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by sh...@apache.org on 2017/07/07 04:24:39 UTC
[27/28] lucene-solr:feature/autoscaling: SOLR-11024: ParallelStream
should set the StreamContext when constructing SolrStreams
SOLR-11024: ParallelStream should set the StreamContext when constructing SolrStreams
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/7051a791
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/7051a791
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/7051a791
Branch: refs/heads/feature/autoscaling
Commit: 7051a7919fad3a4c90e66a70d05ddb54367b4926
Parents: a31f9e8
Author: Joel Bernstein <jb...@apache.org>
Authored: Thu Jul 6 20:53:58 2017 -0400
Committer: Joel Bernstein <jb...@apache.org>
Committed: Thu Jul 6 20:54:19 2017 -0400
----------------------------------------------------------------------
.../java/org/apache/solr/client/solrj/io/stream/ParallelStream.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/7051a791/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
----------------------------------------------------------------------
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
index 58ba248..5c89a76 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
@@ -267,6 +267,7 @@ public class ParallelStream extends CloudSolrStream implements Expressible {
String url = shardUrls.get(w);
SolrStream solrStream = new SolrStream(url, paramsLoc);
+ solrStream.setStreamContext(streamContext);
solrStreams.add(solrStream);
}