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