Skip to content

[Bug] [编译运行] master分支及1.12_release编译后的tar包无法运行内置stream示例 #1042

@zhengchaoken

Description

@zhengchaoken

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

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions