我有一个flink作业,它希望在运行时可以使用另一个依赖jar。是否可以在flink集群中提交具有多个jar的作业。我不能造一个普通的jar。
41ik7eoe1#
您可以在flink/lib文件夹中的每个flink节点上安装依赖项jar,如下所述。这样,用户上传的jar就可以使用它,而不需要用户将它与jar捆绑在一起。请记住,这将完全在作业提交api之外处理,因此您必须将其合并到用于管理flink节点上配置的任何系统中。
1条答案
按热度按时间41ik7eoe1#
您可以在flink/lib文件夹中的每个flink节点上安装依赖项jar,如下所述。这样,用户上传的jar就可以使用它,而不需要用户将它与jar捆绑在一起。
请记住,这将完全在作业提交api之外处理,因此您必须将其合并到用于管理flink节点上配置的任何系统中。