Hi,
You can use the following API to add all the dependent jar packages you
need:
table_env.get_config().get_configuration().set_string("pipeline.jars",
"file:///my/jar/path/connector.jar;file:///my/jar/path/json.jar")
For more related content, you can refer to the pyflink doc[1]
[1]
https://ci.
Hi,
are you using the SQL jars or do you build the dependency jar file
yourself? It might be the case that the SQL jar for Kafka does not
include this module as the exception indicates. You might need to build
a custom Kafka jar with Maven and all dependencies you need. (including
correct MET
Hi,
I am using Flink 1.11.2 version Python Table API to connect to Kafka Topic
using SASL protocol but it fails with the following error. I tried the same
properties in Flink java version, and I am able to connect. Has anyone
faced this issue and how did you resolve it?
Error:
Caused by: javax.s
