[SPARK-20496][SS] Bug in KafkaWriter Looks at Unanalyzed Plans
## What changes were proposed in this pull request? We didn't enforce analyzed plans in Spark 2.1 when writing out to Kafka. ## How was this patch tested? New unit test. Please review http://spark.apache.org/contributing.html before opening a pull request. Author: Bill Chambers <bill@databricks.com> Closes #17804 from anabranch/SPARK-20496-2. (cherry picked from commit 733b81b8) Signed-off-by:Burak Yavuz <brkyvz@gmail.com>
Showing
- external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaWriter.scala 2 additions, 2 deletions...ain/scala/org/apache/spark/sql/kafka010/KafkaWriter.scala
- external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSinkSuite.scala 16 additions, 0 deletions.../scala/org/apache/spark/sql/kafka010/KafkaSinkSuite.scala
Loading
Please register or sign in to comment