scalaapache-flinkdelta

Class not found when using flink sql to write delta table

Guys When I am trying to write the delta table in flink sql, it wrote few data successfully and then it throw an exception when it continues writing:

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

fix my issue and reslove this bug

Solution

  • Flink not supporting Scala 2.13. You should use 2.12 (only supports Scala 2.12.7) Look here