在 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