[jira] [Commented] (SPARK-25937) Support user-defined schema in Kafka Source & Sink

2018-11-06 Thread Jackey Lee (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676374#comment-16676374 ] Jackey Lee commented on SPARK-25937: Not exactly the same thing. The current implementation is to

[jira] [Commented] (SPARK-25937) Support user-defined schema in Kafka Source & Sink

2018-11-05 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676098#comment-16676098 ] Jungtaek Lim commented on SPARK-25937: -- Could you share what is the issue while crafting

[jira] [Commented] (SPARK-25937) Support user-defined schema in Kafka Source & Sink

2018-11-05 Thread Jackey Lee (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674981#comment-16674981 ] Jackey Lee commented on SPARK-25937: [~kabhwan] Good point. It is exactly how I want to solve this

[jira] [Commented] (SPARK-25937) Support user-defined schema in Kafka Source & Sink

2018-11-04 Thread Jungtaek Lim (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674665#comment-16674665 ] Jungtaek Lim commented on SPARK-25937: -- Another thought for my side: maybe we can classify various

[jira] [Commented] (SPARK-25937) Support user-defined schema in Kafka Source & Sink

2018-11-04 Thread Yuanjian Li (JIRA)
[ https://issues.apache.org/jira/browse/SPARK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674630#comment-16674630 ] Yuanjian Li commented on SPARK-25937: - The problem described here need to be resolved, but