Fllink table 使用過程當中沒法找到TableFactory的子類如KafkaSourceSinkFactory StreamTableSourceFactory等

我正在使用flink表api,使用kafka做爲輸入源,使用json做爲表模式。提交程序時出現此錯誤:`程序完成如下異常:html org.apache.flink.client.program.ProgramInvocationException: The main method caused an error. at org.apache.flink.client.program.Packa
相關文章
相關標籤/搜索