[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

sql program throw exception when new kafka with csv format

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.