Search before asking
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?
Code of Conduct
Search before asking
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?
Code of Conduct