Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/spark/pull/22282#discussion_r214638140
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala
---
@@ -1254,6 +1254,9 @@ abstract class KafkaSourceSuiteBase extends
KafkaSourceTest {
.option("startingOffsets", s"earliest")
.option("subscribe", topic)
.load()
+ .selectExpr(
--- End diff --
It would be better if we check exhaustive columns here, so adding check for
headers sounds better to me instead of limiting columns.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
