部署时Flink connector放置位置

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

部署时Flink connector放置位置

automths
Hi:

flink on yarn 上,我可能会用到好多个connector,比如hbase、kafka、es、mysql,我想在flink的安装位置提前把这些connector以及connector所依赖的包给准备好,然后用户开发的包中就可以不用在包含这些包了。
我目前知道的是可以放到flink安装包的/lib目录下,但是这样看起来好乱,而且也不好管理,可能有些还会有共同的依赖,如果版本不一致,可能会导致冲突。
我看有一个plugin目录,我按照plugin目录下面的README准备,发现用的时候class path中并没有生效。


所以,有没有一种比都放到lib下面更好的优雅的方式,比如plugin样的?


















祝好!
automths