Hi Arvid, I'm currently running PyFlink locally in the JVM with a parallelism of 1, and the same file works fine if i direct it to a Kafka cluster (running in a local docker instance).
I assumed that the JAR pipeline definition in the python file would make sure they are made available on the cluster (or in this case the local JVM), right? But if i need to verify the JVM has access to the JAR files, i need a bit of guidance how to do that. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
