You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2016/07/13 09:44:11 UTC
spark git commit: [SPARK-15889][STREAMING] Follow-up fix to erroneous
condition in StreamTest
Repository: spark
Updated Branches:
refs/heads/master 772c213ec -> c190d89bd
[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 <so...@cloudera.com>
Closes #14133 from srowen/SPARK-15889.2.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c190d89b
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c190d89b
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c190d89b
Branch: refs/heads/master
Commit: c190d89bd3cf677400c49238498207b87da9ee78
Parents: 772c213
Author: Sean Owen <so...@cloudera.com>
Authored: Wed Jul 13 10:44:07 2016 +0100
Committer: Sean Owen <so...@cloudera.com>
Committed: Wed Jul 13 10:44:07 2016 +0100
----------------------------------------------------------------------
.../src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/c190d89b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala
----------------------------------------------------------------------
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 f949652..af2b581 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)
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org