fix bug and style

apache · Feb 10, 2016 · d7b1d97 · d7b1d97
1 parent b0d5533
commit d7b1d97
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQueryManagerSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/ContinuousQueryManagerSuite.scala
@@ -28,7 +28,7 @@ import org.scalatest.time.Span
 import org.scalatest.time.SpanSugar._
 
 import org.apache.spark.SparkException
-import org.apache.spark.sql.{ContinuousQueryException, ContinuousQuery, Dataset, StreamTest}
+import org.apache.spark.sql.{ContinuousQuery, Dataset, StreamTest}
 import org.apache.spark.sql.execution.streaming.{MemorySink, MemoryStream, StreamExecution, StreamingRelation}
 import org.apache.spark.sql.test.SharedSQLContext
 
@@ -221,8 +221,8 @@ class ContinuousQueryManagerSuite extends StreamTest with SharedSQLContext with
       require(!q4.isActive)
       val q5 = stopRandomQueryAsync(10 milliseconds, withError = true)
       eventually(Timeout(streamingTimeout)) { require(!q5.isActive) }
-      // After q4 terminates with exception, awaitAnyTerm should start throwing exception
-      //testAwaitAnyTermination(ExpectException[SparkException], awaitTimeout = 100 milliseconds)
+      // After q5 terminates with exception, awaitAnyTerm should start throwing exception
+      testAwaitAnyTermination(ExpectException[SparkException], awaitTimeout = 100 milliseconds)
     }
   }