Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/17395#discussion_r107822893
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
---
@@ -292,7 +292,10 @@ object FileFormatWriter
Github user uncleGen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17395#discussion_r107821138
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
---
@@ -292,7 +292,10 @@ object FileFormatWriter
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/17395#discussion_r107652020
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
---
@@ -292,7 +292,10 @@ object FileFormatWriter
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/17395#discussion_r107650990
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
---
@@ -292,7 +292,10 @@ object FileFormatWriter
Github user uncleGen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17395#discussion_r107650070
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
---
@@ -292,7 +292,10 @@ object FileFormatWriter
Github user uncleGen commented on a diff in the pull request:
https://github.com/apache/spark/pull/17395#discussion_r107637615
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
---
@@ -292,7 +292,10 @@ object FileFormatWriter
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/17395#discussion_r107611325
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/FileFormatWriter.scala
---
@@ -292,7 +292,10 @@ object FileFormatWriter
GitHub user uncleGen opened a pull request:
https://github.com/apache/spark/pull/17395
[SPARK-20065][SS] Avoid to output empty parquet files
## Problem Description
Reported by Silvio Fiorito
I've got a Kafka topic which I'm querying, running a windowed aggregation,
