Skip to content

Commit c190d89

Browse files
committed
[SPARK-15889][STREAMING] Follow-up fix to erroneous condition in StreamTest
## What changes were proposed in this pull request? A second form of AssertQuery now actually invokes the condition; avoids a build warning too ## How was this patch tested? Jenkins; running StreamTest Author: Sean Owen <[email protected]> Closes #14133 from srowen/SPARK-15889.2.
1 parent 772c213 commit c190d89

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ trait StreamTest extends QueryTest with SharedSQLContext with Timeouts {
189189
}
190190

191191
def apply(message: String)(condition: StreamExecution => Unit): AssertOnQuery = {
192-
new AssertOnQuery(s => { condition; true }, message)
192+
new AssertOnQuery(s => { condition(s); true }, message)
193193
}
194194
}
195195

0 commit comments

Comments
 (0)