Re: Why dont't have a csv formatter for kafka table source

[Till Rohrmann <tr...@apache.org>]

Hi Jocean,

these kind of issues should go to the user mailing list. I've cross posted
it there and put dev to bcc.

Cheers,
Till

On Fri, Nov 2, 2018 at 6:43 AM Jocean shi <jo...@gmail.com> wrote:

> Hi all，
>      I have  encountered a error When i want to register a table from kafka
> using csv formatter.
>      The error is "Could not find a suitable table factory for
> 'org.apache.flink.table.factories.DeserializationSchemaFactory"
>
> Jocean
>

Re: Why dont't have a csv formatter for kafka table source

[Timo Walther <tw...@apache.org>]

I already answered his question but forgot to CC the mailing list:

Hi Jocean,

a standard compliant CSV format for a Kafka table source is in the 
making right now. There is a PR that implements it [1] but it needs 
another review pass. It is high on my priority list and I hope we can 
finalize it after the 1.7 release is out. Feel free to help here by 
reviewing and trying it out.

Regards,
Timo

[1] https://github.com/apache/flink/pull/6541


Am 02.11.18 um 10:11 schrieb Till Rohrmann:
> Hi Jocean,
>
> these kind of issues should go to the user mailing list. I've cross 
> posted it there and put dev to bcc.
>
> Cheers,
> Till
>
> On Fri, Nov 2, 2018 at 6:43 AM Jocean shi <jocean.shi@gmail.com 
> <ma...@gmail.com>> wrote:
>
>     Hi all，
>          I have  encountered a error When i want to register a table
>     from kafka
>     using csv formatter.
>          The error is "Could not find a suitable table factory for
>     'org.apache.flink.table.factories.DeserializationSchemaFactory"
>
>     Jocean
>