Github user gengliangwang commented on a diff in the pull request:
https://github.com/apache/spark/pull/20386#discussion_r164703291
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/sources/ConsoleWriterSuite.scala
---
@@ -34,9 +33,9 @@ class ConsoleWriterSuite extends StreamTest {
Console.withOut(captured) {
val query = input.toDF().writeStream.format("console").start()
try {
- input.addData(1, 2, 3)
+ input.addData(1, 1, 1)
--- End diff --
The order of collected messages is not the same as input data any more.
To make the test case working, we should either change input data to same
elements, or set `spark.default.parallelism` as 1.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
