[Bug] [Module Name] Bug title

The report enters through com.dtstack.chunjun.Main.exeSyncJob (Main.java:242), then LocalClusterClientHelper.submit and Launcher.main. Reproduce the Kingbase-to-Kafka job on master with the shown connector path and inspect the JAR configuration involved in the failure; done means the job no longer raises MalformedURLException and the expected synchronization behavior is confirmed.

Search before asking

• I had searched in the issues and found no similar issues.

What happened

完整堆栈信息,环境是最新版本,master分支
从kingbase同步到kafka
2025-03-18 19:43:30,166 WARN org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer - Property [transaction.timeout.ms] not specified. Setting it to 3600000 ms
Exception in thread "main" java.net.MalformedURLException: no protocol: /data/chunjun2/chunjun-dist-master/chunjun-dist/connector/kingbase/chunjun-connector-kingbase.jar
at java.net.URL.(URL.java:593)
at java.net.URL.(URL.java:490)
at java.net.URL.(URL.java:439)
at org.apache.flink.configuration.ConfigUtils.decodeListFromConfig(ConfigUtils.java:133)
at org.apache.flink.client.cli.ExecutionConfigAccessor.getJars(ExecutionConfigAccessor.java:77)
at org.apache.flink.client.deployment.executors.PipelineExecutorUtils.getJobGraph(PipelineExecutorUtils.java:69)
at org.apache.flink.client.deployment.executors.LocalExecutor.getJobGraph(LocalExecutor.java:105)
at org.apache.flink.client.deployment.executors.LocalExecutor.execute(LocalExecutor.java:82)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2188)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2075)
at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:68)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2049)
at com.dtstack.chunjun.Main.exeSyncJob(Main.java:242)
at com.dtstack.chunjun.Main.main(Main.java:139)
at com.dtstack.chunjun.client.local.LocalClusterClientHelper.submit(LocalClusterClientHelper.java:30)
at com.dtstack.chunjun.client.Launcher.main(Launcher.java:87)

What you expected to happen

1

How to reproduce

缺失sink端的kafka吗

Anything else

No response

Version

master

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