我正在kubernetes(会话群集)上部署一个flink集群,我想知道是否有任何配置(在flink-conf.yaml上),我会将外部jar加载到该集群。
到目前为止,我知道flink将加载lib /文件夹下的所有jar,但是可以说我想上传jar以获取指标,并且我不想手动将其放在lib文件夹中(因为每次部署它都会删除它),而我不想要将lib /文件夹挂载。
我想要的解决方案是制作一个/ mnt / external-jars库(将是一个安装文件,并且flink将把该目录中的所有jar加载到它的类路径中。)>
有可能吗?
我正在kubernetes(会话群集)上部署一个flink集群,我想知道是否有任何配置(在flink-conf.yaml上),我会将外部jar加载到该集群。据我所知...
您可以使用配置选项pipeline.classpaths
,该选项采用分号分隔的类路径列表。运行Flink客户端时,将读取此配置选项。在将类路径提交给集群之前,会将其添加到生成的Flink JobGraph
中。注意,必须从群集节点访问类路径。