[lucene-solr] 01/13: @734 Close stream in test.

[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

commit b6a98479e29ab2ba6959822a013c218478f7acdc
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Fri Sep 4 07:07:58 2020 -0500

    @734 Close stream in test.
---
 .../org/apache/solr/client/solrj/io/stream/StreamDecoratorTest.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamDecoratorTest.java b/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamDecoratorTest.java
index 55b9858..7da79fb 100644
--- a/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamDecoratorTest.java
+++ b/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamDecoratorTest.java
@@ -2981,6 +2981,9 @@ public class StreamDecoratorTest extends SolrCloudTestCase {
       }
 
       assertEquals(cluster.getJettySolrRunners().size(), workersComplete);
+
+      parallelUpdateStream.close();
+
       //Ensure that destinationCollection actually has the new docs.
       expression = StreamExpressionParser.parse("search(parallelDestinationCollection1, q=*:*, fl=\"id,a_s,a_i,a_f,s_multi,i_multi\", sort=\"a_i asc\")");
       stream = new CloudSolrStream(expression, factory);