Re: pyflink 和 add_jars 的 add_classpaths 路径。

Tue, 26 Jul 2022 19:40:24 -0700 

pyflink情况 flink-sql-connector-kafka-1.15.0.jar 可以。
但 flink-connector-base-1.15.0.jar + flink-connector-kafka-1.15.0.jar +
kafka-clients-2.8.1.jar 却报：
py4j.protocol.Py4JError:
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer does
not exist in the JVM

Weihua Hu <[email protected]> 于2022年7月26日周二 21:21写道：
>
> 最终会放到 pipeline.jars 配置中，在提交作业时上传到 blobServer
>
> Best,
> Weihua
>
>
> On Tue, Jul 26, 2022 at 5:40 PM yidan zhao <[email protected]> wrote:
>
> > 如题，我看注释和文档。
> > add_jars 是添加要upload到cluster的jar，那么上传到什么路径呢？
> >

回复