包装flink作业时,该作业使用一些弗林克连接器和一些第三方库(用于处理),这些依赖项应最终出现在Jobs Jar中,因此可以在一个中启动使用(" flink run [jarfile]")?
正在制作脂肪 -
如果在Scala中写作业,您是否在JAR中包括Scala默认库?
我找不到有关如何打包弗林克一旦写作的任何文档。
是的,脂肪jar是包装flink作业的标准方法。不得包括弗林克分布中包含的所有内容(即,Java和比例默认库,Flink Core,...)。脂肪Jar中只能包含一些未包含的Flink库(加上用户定义的外部依赖项)。
您可以从Flink Documenation遵循此准则:https://ci.apache.org/projects/flink/flink/flink/flink/flink/flink-docs-release-1.0/apis/cluster_execution.html#linking-with-with-modules-not-not-not-not-not-doct - 二进制分布
这也可能会有所帮助:https://ci.apache.org/projects/flink/flink/flink/flink-docs-release-1.0/apis/common/index.html#program-packaging-packaging-program-packaging-algage-and-distribed-distributed-execution-p>