什么应该从Apache中排除？

Question

当打包使用flink连接器和第三方库(用于处理)的flink作业时，哪些依赖项应该在jar中结束，这样就可以使用("flink run jarfile")在flink集群中启动它？

做一个胖罐子是你想要的方法吗？

如果用scala编写作业，是否在jar中包含scala默认库？

我没有找到任何有关如何打包flink的作业的文档。

Answer 1

是的，一个胖罐子是包装Flink作业的标准方法。不应包含Flink发行版中包含的所有内容(例如，Java和缩放默认库、Flink核心、.)。只有一些不包含的Flink库(加上用户定义的外部依赖项)必须包含在胖jar中。

您可以遵循Flink文档中的以下指导原则：execution.html#linking-with-modules-not-contained-in-the-binary-distribution

这也可能有帮助：https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/common/index.html#program-packaging-and-distributed-execution