Re:Re: Could not find any factory for identifier 'kafka'

2020-07-24 文章 RS
hi, 感谢回复,尝试了多次之后,发现应该不是依赖包的问题 我项目中新增目录:resources/META-INF/services 然后从Flink源码中复制了2个文件 org.apache.flink.table.factories.TableFactory和org.apache.flink.table.factories.Factory 这样编译就不会报错了,原理不太清楚,但是确实解决了报错的问题。 在 2020-07-24 20:16:18,"JasonLee" <17610775...@163.com> 写道: >hi >只需要-sql和-json两个包就可以了 > >

Re:Re: Could not find any factory for identifier 'kafka'

2020-07-24 文章 RS
我这边是直接打成jar包扔到服务器上运行的(bin/flink run xxx),没有在IDEA运行过。maven编译没配置shade-plugin,maven build参数如下: propertiesjdk.version1.8/jdk.version flink.version1.11.1/flink.version /propertiesbuildplugins plugin