大家.我尝试在Flink中引用我的公司jar,将其复制到所有任务管理器中的$ FLINK/lib,但是失败了.而且我不想打包一个肥胖的罐子,这个罐子太沉重而且浪费时间.我认为第一种方法也不是一个好主意,因为我必须管理整个集群中的jar.谁知道如何解决这个问题？任何建议将不胜感激.
Mat*_*Sax 13
一般来说,建造一个肥胖的罐子是最好的方式.不知道你的远远的罐子有多大,你认为它"太重了"？
复制罐子$FLINK/lib应该工作.但是,您需要重新启动Flink,以便将jar添加到Flink的类路径中.因此,这种方法不允许动态添加罐子 - 但它应该适用于一堆稳定的罐子.
为了管理整个集群中的jar,使用NFS文件夹可能有助于$FLINK/lib保持所有TaskManagers同步.或者你简单地编写一个bash脚本来分发你的jar.
| 归档时间： |
|
| 查看次数： |
3083 次 |
| 最近记录： |