使用flink sql写入delta表时未找到类

hujrc8aj  于 12个月前  发布在  Apache
关注(0)|答案(1)|浏览(149)

当我尝试在flink sql中写入delta表时,它成功地写入了一些数据,然后在继续写入时抛出异常:

Caused by: java.lang.NoSuchMethodError: scala.jdk.CollectionConverters$.mapAsJavaMapConverter(Lscala/collection/Map;)Lscala/collection/convert/Decorators$AsJava;

字符串
My env:FLink version:1.16.0 hadoop:3.3.1 delta:3.0.0 scala:2.13
修复我的问题并解决此错误

2hh7jdfx

2hh7jdfx1#

Flink不支持Scala 2.13。您应该使用2.12(仅支持Scala 2.12.7)Look here

相关问题