Kubernetes 上的 flink 将外部 jar 加载到集群答案

【问题标题】：flink on kubernetes load external jars to clusterKubernetes 上的 flink 将外部 jar 加载到集群
【发布时间】：2020-03-14 09:36:51
【问题描述】：

我正在 kubernetes（会话集群）上部署一个 flink 集群，我想知道是否有任何配置（在 flink-conf.yaml 上）我会将外部 jar 加载到集群中。

据我所知，flink 将加载 lib/ 文件夹下的所有 jar，但可以说我想上传 jar 用于度量，我不想手动将它放在 lib 文件夹中（因为每次部署它都会删除它），我不想让 lib/ 文件夹成为挂载。

我想要的解决方案是创建一个 /mnt/external-jars 库（这将是一个挂载），flink 会将这个目录中的所有 jar 加载到它的类路径中。

有没有可能？

【问题讨论】：

【解决方案1】：

您可以使用配置选项pipeline.classpaths，它采用分号分隔的类路径列表。运行 Flink 客户端时会读取此配置选项。在提交到集群之前，类路径将添加到生成的 Flink JobGraph。请注意，类路径必须可从集群节点访问。

pipeline.classpaths: file:///mnt/external-jars/MyJar.jar;file:///foobar/other-jars/MyJar2.jar

【讨论】：