Fix test

apache · Feb 10, 2016 · 9caec83 · 9caec83
1 parent 1902593
commit 9caec83
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/StreamTest.scala b/sql/core/src/test/scala/org/apache/spark/sql/StreamTest.scala
@@ -298,7 +298,8 @@ trait StreamTest extends QueryTest with Timeouts {
               verify(!currentStream.isActive,
                 "query.isActive() is false even after stopping")
               verify(currentStream.exception.isEmpty,
-                "query.exception() is not empty after clean stop")
+                s"query.exception() is not empty after clean stop: " +
+                  currentStream.exception.map(_.toString()).getOrElse(""))
             } catch {
               case _: InterruptedException =>
               case _: org.scalatest.exceptions.TestFailedDueToTimeoutException =>
@@ -434,7 +435,8 @@ trait StreamTest extends QueryTest with Timeouts {
           case r if r < 0.7 => // AddData
             addRandomData()
 
-          case _ => // StartStream
+          case _ => // StopStream
+            addCheck()
             actions += StopStream
             running = false
         }