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 58ba248d44b..5c89a76a772 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); }