Address comments

lw-lin · lw-lin · commit 63ed28ac1f90 · 2017-05-03T08:06:04.000+08:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamSuite.scala
@@ -154,6 +154,7 @@ class StreamSuite extends StreamTest {
           .start()
           .asInstanceOf[StreamingQueryWrapper]
           .streamingQuery
+      query.awaitInitialization(streamingTimeout.toMillis)
       val executionRelations =
         query
           .logicalPlan
