在flink中使用kafkasql遇到Could not find any factory for identifier ‘json‘ that implements ‘org.apache.这个问题
·
遇到这种问题不要慌，先拍照发个朋友圈
那么这种问题出现的原因主要是因为缺少了json的jar包，而解决的方法也很简单，和解决hive和spark中出现类似的问题一样。
那就是将json包给进行导入就好了,这是我的版本，具体自己适配的版本要自行查询吼。
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-json</artifactId>
<version>1.17.2</version>
</dependency>
如果你不是使用的pom文件进行导包的话还有另一种方法，更加直接简单粗暴，那就是——去官网下载好了以后拉进来
下面的是这个包所在的位置，可自行进行下载
操作完之后再运行就OK啦
更多推荐
7
0- 0
已为社区贡献4条内容
所有评论(0)