在 flink 集群部署 alink,需要部署三个 jar 包(本文会有一个部分专门讲述如何获取),对于不同 flink 集群环境,方式有些区别,本文主要讨论 standalone 集群和 kubernetes 集群。
获取集群部署所需 jar 包
由于 alink 可以通过 java 和 python 两种方式提交,建议在集群部署的时候将相关 jar 包一起部署上去。alink 虽然没有单独提供集群部署 jar 包的下载,但是所需 jar 包与 pyalink 所用的相同。所以可以从 pyalink 的安装 whl 包中获取。具体方式如下:
1.下载 pyalink 1.10 的 whl 包,相关链接:
https://github.com/alibaba/alink/releases/tag/v1.1.0
2.解压 pyalink 1.10 的 whl 包
解压后的文件结构如下图所示,在 pyalink/lib 下为集群部署所需的三个 jar 包。
在 standalone 集群上部署
将前面获取的三个 jar 包拷贝到 flink 目录下,再启动 flink 集群即可。
在 flink 配置中增加:classloader.resolve-order: parent-first
在 flink-[版本号]目录下,运行 bin/start-cluster.sh 启动集群
bin/taskmanager.sh start 可以增加 tm
办理注册商标用的个体营业执照吗云服务器租赁价格一年多少钱seo就是每天发帖子,写文章,发外链?阿里云服务器怎么转移不买阿里云的服务器如何备案搭建网站云服务器配置HAProxy日志配置,日志怎么打开?E3 2016微软公布跨平台游戏服务Xbox Play Anywhere