Github user brkyvz commented on a diff in the pull request:
https://github.com/apache/spark/pull/17613#discussion_r111067826
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -284,42 +284,38 @@ class StreamExecution(
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/17613#discussion_r111058990
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala ---
@@ -277,6 +277,11 @@ trait StreamTest extends QueryTest with
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/17613#discussion_r111058917
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -284,42 +284,38 @@ class StreamExecution(
GitHub user brkyvz opened a pull request:
https://github.com/apache/spark/pull/17613
[SPARK-20301][FLAKY-TEST][DO NOT MERGE] Fix Hadoop Shell.runCommand
flakiness in Structured Streaming tests
## What changes were proposed in this pull request?
Some Structured Streaming