You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/02/27 19:27:00 UTC

[jira] [Resolved] (FLINK-8538) Add a Kafka table source factory with JSON format support

     [ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timo Walther resolved FLINK-8538.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 1.6.0
                   1.5.0

Fixed in 1.6.0: 2450d2b24006a4db846b9b688f9b598e3fdf7c6e & d9f2f2f83c8a099e687e158705375db1b56dca01
Fixed in 1.5.0: 1d26062de130c05fdbe7701b55766b4a8d433418 & db2c510fb4f171c9e9940759e5fbaf466ec74474

> Add a Kafka table source factory with JSON format support
> ---------------------------------------------------------
>
>                 Key: FLINK-8538
>                 URL: https://issues.apache.org/jira/browse/FLINK-8538
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table API &amp; SQL
>            Reporter: Timo Walther
>            Assignee: Xingcan Cui
>            Priority: Major
>             Fix For: 1.5.0, 1.6.0
>
>
> Similar to CSVTableSourceFactory a Kafka table source factory for JSON should be added. This issue includes improving the existing JSON descriptor with validation that can be used for other connectors as well. It is up for discussion if we want to split the KafkaJsonTableSource into connector and format such that we can reuse the format for other table sources as well.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)