sql program throw exception when new kafka with csv format

[Marvin777]

Register kafka message source with csv format,  the error message is as
follows:

Exception in thread "main"
org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find
a suitable table factory for
'org.apache.flink.table.factories.DeserializationSchemaFactory' in
the classpath.


Reason: No context matches.


BTW, the flink version is 1.6.2 .

Thanks Marvin.

[image: image.png]