Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/spark/pull/22282#discussion_r214622654
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala
---
@@ -293,7 +294,12 @@ private[kafka010] class KafkaSource(
cr.partition,
cr.offset,
DateTimeUtils.fromJavaTimestamp(new
java.sql.Timestamp(cr.timestamp)),
- cr.timestampType.id)
+ cr.timestampType.id,
+ UnsafeMapData.of(
+
UnsafeArrayData.fromStringArray(cr.headers().toArray.map(_.key())),
--- End diff --
Same here.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
