spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sro...@apache.org
Subject spark git commit: [SPARK-15889][STREAMING] Follow-up fix to erroneous condition in StreamTest
Date Wed, 13 Jul 2016 09:44:11 GMT
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 <sowen@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 <sowen@cloudera.com>
Authored: Wed Jul 13 10:44:07 2016 +0100
Committer: Sean Owen <sowen@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


Mime
View raw message