java.lang.ClassNotFoundException: org.apache.flink.connector.clickhouse.internal.ClickHouseBatchOutputFormat

[Achilles1996]

编译master 使用flinksql 提交任务 报错

[itinycheng]

任务没加载到connector的jar吧，flink/lib下没放connector或是用错包了(用饱含dependencies的jar)？

[Achilles1996]

加载到connector的jar了，因为在flinksql的client中使用CREATE CATALOG clickhouse了可以查询到有那些数据库，那些表；

我是flink1.16.2的版本，使用了flinksql的方式提交任务，standlone的模式，

呜呜

[itinycheng]

@Achilles1996 如果create ClickHouse Catalog 正常可用说明确实已经加载到jar了； ClassNotFoundException也可能是加载ClickHouseBatchOutputFormat类失败，具体原因还是多看看sql client log吧； 根据以上信息我定位不到具体原因；

[wolfewf]

Caused by: org.apache.flink.runtime.operators.util.CorruptConfigurationException: Could not read the user code wrapper: org.apache.flink.connector.clickhouse.internal.ClickHouseBatchOutputFormat at org.apache.flink.runtime.operators.util.TaskConfig.getStubWrapper(TaskConfig.java:300) at org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.(InputOutputFormatContainer.java:66) ... 18 more Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.clickhouse.internal.ClickHouseBatchOutputFormat at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:581) at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178) at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:527) at java.base/java.lang.Class.forName0(Native Method) at java.base/java.lang.Class.forName(Class.java:398) at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78) at java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2003) 我这边报了这个错误 @itinycheng 这个有解决吗