flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Why dont't have a csv formatter for kafka table source
Date Fri, 02 Nov 2018 09:18:20 GMT
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.


[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 
> <mailto:jocean.shi@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

View raw message