注册

DM8 Flink CDC 连接器工具报错!!

DM-LHS 2025/06/19 110 1

DM8 Flink CDC 连接器工具 参考的这个地址

网页上写支持Flink 1.17.x,我实测运行没有问题。
但是支持达梦这个Flink 1.13.6的版本吗?按照网址给出的下载zip包里面写的支持1.13.*的版本,但是运行报错....到底是支持还是不支持Flink 1.13.*的版本?????

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava18/com/google/common/collect/ImmutableList
at org.apache.flink.table.planner.functions.sql.SqlTumbleTableFunction$OperandMetadataImpl.<init>(SqlTumbleTableFunction.java:45)
at org.apache.flink.table.planner.functions.sql.SqlTumbleTableFunction.<init>(SqlTumbleTableFunction.java:39)
at org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable.<clinit>(FlinkSqlOperatorTable.java:1181)
at org.apache.flink.table.planner.delegation.PlannerContext.getBuiltinSqlOperatorTable(PlannerContext.java:328)
at java.base/java.util.Optional.orElseGet(Optional.java:364)
at org.apache.flink.table.planner.delegation.PlannerContext.getSqlOperatorTable(PlannerContext.java:318)
at org.apache.flink.table.planner.delegation.PlannerContext.createFrameworkConfig(PlannerContext.java:143)
at org.apache.flink.table.planner.delegation.PlannerContext.<init>(PlannerContext.java:121)
at org.apache.flink.table.planner.delegation.PlannerBase.<init>(PlannerBase.scala:103)
at org.apache.flink.table.planner.delegation.StreamPlanner.<init>(StreamPlanner.scala:51)
at org.apache.flink.table.planner.delegation.BlinkPlannerFactory.create(BlinkPlannerFactory.java:48)
at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.create(StreamTableEnvironmentImpl.java:161)
at org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamTableEnvironment.java:128)
at org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamTableEnvironment.java:98)
at org.example.DMFlinkSQL.main(DMFlinkSQL.java:31)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.shaded.guava18.com.google.common.collect.ImmutableList
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:525)
... 15 more

回答 0
暂无回答
扫一扫
联系客服