每个人。我尝试在所有任务管理器中以将其复制到 $FLINK/lib 的方式在 Flink 中引用我的公司 jar，但失败了。而且我不想打包一个胖罐子，太重而且浪费时间。我认为第一种方法也不是一个好主意，因为我必须管理整个集群中的jar。有谁知道如何解决这个问题？任何建议将不胜感激。
一般来说，构建一个胖罐子是最好的方法。不确定您的远罐有多大，您认为它“太重”？
将 jar 复制到$FLINK/lib应该管用。但是，您需要重新启动 Flink，以便将 jar 添加到 Flink 的类路径中。因此，这种方法不允许动态添加 jar——但是它应该适用于一堆稳定的 jar。
为了管理整个集群中的 jar，使用 NFS 文件夹可能会有所帮助$FLINK/lib保持所有任务管理器同步。或者您只需编写一个 bash 脚本来分发您的 jar。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
