-
Notifications
You must be signed in to change notification settings - Fork 1.7k
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
编译后的程序:chunjun-assembly/target/chunjun-assembly-1.12-SNAPSHOT-chunjun-dist.tar.gz
解压后执行默认用例:
sh bin/chunjun-local.sh -job chunjun-examples/json/stream/stream.json
报错如下:
2022-07-13 09:14:21.953 [main] INFO com.dtstack.chunjun.Main - local
2022-07-13 09:14:21.953 [main] INFO com.dtstack.chunjun.Main - -flinkConfDir
2022-07-13 09:14:21.953 [main] INFO com.dtstack.chunjun.Main - /opt/etl/flink-1.12.7/conf
2022-07-13 09:14:21.954 [main] INFO com.dtstack.chunjun.Main - -------------------------------------------
2022-07-13 09:14:21.998 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.address, localhost
2022-07-13 09:14:21.998 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.port, 6123
2022-07-13 09:14:21.998 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.memory.process.size, 1600m
2022-07-13 09:14:21.999 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.memory.process.size, 1728m
2022-07-13 09:14:21.999 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2022-07-13 09:14:21.999 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: parallelism.default, 1
2022-07-13 09:14:21.999 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.execution.failover-strategy, region
2022-07-13 09:14:23.418 [main] INFO com.dtstack.chunjun.Main - Register to table configuration:{table.dynamic-table-options.enabled=true, pipeline.name=Flink_Job}
2022-07-13 09:14:23.464 [main] INFO com.dtstack.chunjun.util.PluginUtil - ChunJun executionMode: local
2022-07-13 09:14:23.464 [main] INFO com.dtstack.chunjun.util.PluginUtil - ChunJun reset pipeline.jars: []
2022-07-13 09:14:23.469 [main] INFO com.dtstack.chunjun.classloader.ClassLoaderManager - jarUrl: create ClassLoad successful...
Exception in thread "main" com.dtstack.chunjun.throwable.ChunJunRuntimeException: java.lang.ClassNotFoundException: com.dtstack.chunjun.connector.stream.source.StreamSourceFactory
at com.dtstack.chunjun.util.DataSyncFactoryUtil.discoverSource(DataSyncFactoryUtil.java:74)
at com.dtstack.chunjun.Main.exeSyncJob(Main.java:185)
at com.dtstack.chunjun.Main.main(Main.java:122)
at com.dtstack.chunjun.client.local.LocalClusterClientHelper.submit(LocalClusterClientHelper.java:35)
at com.dtstack.chunjun.client.Launcher.main(Launcher.java:119)
Caused by: java.lang.ClassNotFoundException: com.dtstack.chunjun.connector.stream.source.StreamSourceFactory
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at com.dtstack.chunjun.util.DataSyncFactoryUtil.lambda$discoverSource$0(DataSyncFactoryUtil.java:67)
at com.dtstack.chunjun.classloader.ClassLoaderSupplierCallBack.callbackAndReset(ClassLoaderSupplierCallBack.java:33)
at com.dtstack.chunjun.classloader.ClassLoaderManager.newInstance(ClassLoaderManager.java:66)
at com.dtstack.chunjun.util.DataSyncFactoryUtil.discoverSource(DataSyncFactoryUtil.java:64)
... 4 more
此类在源码中存在。
What you expected to happen
能正常运行示例
How to reproduce
环境信息:
系统:CentOS Linux release 7.7.1908 (Core)
JDK:java version "1.8.0_162"
FLINK:FLINK_HOME=/opt/etl/flink-1.12.7
编译信息:
对 master分支或1.12_release
执行 sh build/build.sh 或 mvn clean package -DskipTests
获得tar包
Anything else
No response
Version
1.12_release
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct