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....@gmail.com
<mailto:jocean....@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
