我正在kubernetes（session cluster）上部署一个flink集群，我想知道是否有任何配置（在flink-conf.yaml上）可以将外部jar加载到集群中。
据我所知，flink将加载lib/folder下的所有jar，但假设我想上传度量的jar，我不想手动将其放入lib文件夹（因为每次部署它都会删除它），我也不想让lib/folder成为挂载。
我想要的解决方案是创建一个/mnt/externaljars库（这将是一个挂载），flink将把这个目录中的所有jar加载到它的类路径中。
有可能吗？
1条答案
按热度按时间toiithl61#
您可以使用config选项
pipeline.classpaths它采用以分号分隔的类路径列表。运行flink客户机时会读取此配置选项。类路径将被添加到生成的flink中JobGraph在提交到集群之前。注意，类路径必须可以从集群节点访问。