diff --git a/solr/core/src/java/org/apache/solr/handler/StreamHandler.java b/solr/core/src/java/org/apache/solr/handler/StreamHandler.java index dc097be59a3..cbb99108dff 100644 --- a/solr/core/src/java/org/apache/solr/handler/StreamHandler.java +++ b/solr/core/src/java/org/apache/solr/handler/StreamHandler.java @@ -305,7 +305,7 @@ public class StreamHandler extends RequestHandlerBase implements SolrCoreAware, StreamExpression streamExpression = StreamExpressionParser.parse(params.get("expr")); if(this.streamFactory.isEvaluator(streamExpression)) { StreamExpression tupleExpression = new StreamExpression("tuple"); - tupleExpression.addParameter(new StreamExpressionNamedParameter("out", streamExpression)); + tupleExpression.addParameter(new StreamExpressionNamedParameter("return-value", streamExpression)); tupleStream = this.streamFactory.constructStream(tupleExpression); } else { tupleStream = this.streamFactory.constructStream(streamExpression); diff --git a/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java b/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java index cbd57b8fe15..c570d95c733 100644 --- a/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java +++ b/solr/solrj/src/test/org/apache/solr/client/solrj/io/stream/StreamExpressionTest.java @@ -5220,7 +5220,7 @@ public class StreamExpressionTest extends SolrCloudTestCase { solrStream.setStreamContext(context); List tuples = getTuples(solrStream); assertTrue(tuples.size() == 1); - List sequence = (List)tuples.get(0).get("out"); + List sequence = (List)tuples.get(0).get("return-value"); assertTrue(sequence.size() == 20); for(int i=0; i