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

[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 <[hidden email]> 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

[Timo Walther]

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 <[hidden email]> 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