You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by cp...@apache.org on 2022/08/08 17:24:11 UTC
[solr] branch branch_9x updated: SOLR-16286: simplify StreamDecoratorTest.test[Parallel]PriorityStream (#950)
This is an automated email from the ASF dual-hosted git repository.
cpoerschke pushed a commit to branch branch_9x
in repository https://gitbox.apache.org/repos/asf/solr.git
The following commit(s) were added to refs/heads/branch_9x by this push:
new 662e1206989 SOLR-16286: simplify StreamDecoratorTest.test[Parallel]PriorityStream (#950)
662e1206989 is described below
commit 662e1206989f172ead4a6ab2f8e535bc7973a834
Author: Christine Poerschke <cp...@apache.org>
AuthorDate: Mon Aug 8 18:18:49 2022 +0100
SOLR-16286: simplify StreamDecoratorTest.test[Parallel]PriorityStream (#950)
(cherry picked from commit 7c07970f972890230862fb1a5665e3c51486828b)
---
.../solrj/io/stream/StreamDecoratorTest.java | 32 ----------------------
1 file changed, 32 deletions(-)
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 34fee1bd09f..70bf46edbaf 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
@@ -3028,14 +3028,6 @@ public class StreamDecoratorTest extends SolrCloudTestCase {
assertEquals(tuples.size(), 4);
assertOrder(tuples, 5, 6, 7, 8);
- expression =
- StreamExpressionParser.parse(
- "priority(topic(collection1, collection1, q=\"a_s:hello\", fl=\"id,a_i\", id=1000000, initialCheckpoint=0),"
- + "topic(collection1, collection1, q=\"a_s:hello1\", fl=\"id,a_i\", id=2000000, initialCheckpoint=0))");
- stream = factory.constructStream(expression);
- context = new StreamContext();
- context.setSolrClientCache(cache);
- stream.setStreamContext(context);
tuples = getTuples(stream);
Collections.sort(tuples, comp);
@@ -3043,14 +3035,6 @@ public class StreamDecoratorTest extends SolrCloudTestCase {
assertEquals(tuples.size(), 6);
assertOrder(tuples, 0, 1, 2, 3, 4, 9);
- expression =
- StreamExpressionParser.parse(
- "priority(topic(collection1, collection1, q=\"a_s:hello\", fl=\"id,a_i\", id=1000000, initialCheckpoint=0),"
- + "topic(collection1, collection1, q=\"a_s:hello1\", fl=\"id,a_i\", id=2000000, initialCheckpoint=0))");
- stream = factory.constructStream(expression);
- context = new StreamContext();
- context.setSolrClientCache(cache);
- stream.setStreamContext(context);
tuples = getTuples(stream);
// Both queus are empty.
@@ -3110,14 +3094,6 @@ public class StreamDecoratorTest extends SolrCloudTestCase {
assertEquals(tuples.size(), 4);
assertOrder(tuples, 5, 6, 7, 8);
- expression =
- StreamExpressionParser.parse(
- "parallel(collection1, workers=2, sort=\"_version_ asc\", priority(topic(collection1, collection1, q=\"a_s:hello\", fl=\"id,a_i\", id=1000000, initialCheckpoint=0, partitionKeys=id),"
- + "topic(collection1, collection1, q=\"a_s:hello1\", fl=\"id,a_i\", id=2000000, initialCheckpoint=0, partitionKeys=id)))");
- stream = factory.constructStream(expression);
- context = new StreamContext();
- context.setSolrClientCache(cache);
- stream.setStreamContext(context);
tuples = getTuples(stream);
Collections.sort(tuples, comp);
@@ -3125,14 +3101,6 @@ public class StreamDecoratorTest extends SolrCloudTestCase {
assertEquals(tuples.size(), 6);
assertOrder(tuples, 0, 1, 2, 3, 4, 9);
- expression =
- StreamExpressionParser.parse(
- "parallel(collection1, workers=2, sort=\"_version_ asc\", priority(topic(collection1, collection1, q=\"a_s:hello\", fl=\"id,a_i\", id=1000000, initialCheckpoint=0, partitionKeys=id),"
- + "topic(collection1, collection1, q=\"a_s:hello1\", fl=\"id,a_i\", id=2000000, initialCheckpoint=0, partitionKeys=id)))");
- stream = factory.constructStream(expression);
- context = new StreamContext();
- context.setSolrClientCache(cache);
- stream.setStreamContext(context);
tuples = getTuples(stream);
// Both queus are empty.