Hi Joris,
Are you sure that all nodes have access to these jars? Usually, shared
resources reside on some kind of distributed file system or network
directory.
I'm pulling in Dian who can probably help better.
Best,
Arvid
On Tue, Feb 9, 2021 at 1:50 PM joris.vanagtmaal <
joris.vanagtm...@wartsila.com> wrote:
> hi Yun,
>
> thanks for the help!
>
> if i direct the Kafka connector in the DDL to a local Kafka cluster, it
> works fine. So i assume access to the JAR files should not be the issue.
>
> This is how i referred to the JAR files from Python:
> t_env.get_config().get_configuration().set_string("pipeline.jars",
>
> "file:///Users/jag002/flinkjars/flink-connector-kafka_2.11-1.13-SNAPSHOT.jar;file:///Users/jag002/flinkjars/flink-sql-connector-kafka_2.11-1.13-SNAPSHOT.jar;file:///Users/jag002/flinkjars/kafka-clients-2.7.0.jar")
>
> All the best,
> Joris
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>
