diff options
| author | Sean Owen <sowen@cloudera.com> | 2016-07-13 10:44:07 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-07-13 10:44:07 +0100 |
| commit | c190d89bd3cf677400c49238498207b87da9ee78 (patch) | |
| tree | 1a36e7e7df2dbf502d1703a5eb39492c6b973333 /sql/core/src/test | |
| parent | 772c213ec702c80d0f25aa6f30b2dffebfbe2d0d (diff) | |
| download | spark-c190d89bd3cf677400c49238498207b87da9ee78.tar.gz spark-c190d89bd3cf677400c49238498207b87da9ee78.tar.bz2 spark-c190d89bd3cf677400c49238498207b87da9ee78.zip | |
[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 <sowen@cloudera.com>
Closes #14133 from srowen/SPARK-15889.2.
Diffstat (limited to 'sql/core/src/test')
| -rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala index f9496520f3..af2b58116b 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala @@ -189,7 +189,7 @@ trait StreamTest extends QueryTest with SharedSQLContext with Timeouts { } def apply(message: String)(condition: StreamExecution => Unit): AssertOnQuery = { - new AssertOnQuery(s => { condition; true }, message) + new AssertOnQuery(s => { condition(s); true }, message) } } |