在 Flink 集群部署 Alink,需要部署三個 Jar 包(本文會有一個部分專門講述如何獲?。瑢τ诓煌?Flink 集群環(huán)境,方式有些區(qū)別,本文主要討論 Standalone 集群和 Kubernetes 集群。
讓客戶滿意是我們工作的目標(biāo),不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶,將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴,公司提供的服務(wù)項(xiàng)目有:主機(jī)域名、網(wǎng)站空間、營銷軟件、網(wǎng)站建設(shè)、柳城網(wǎng)站維護(hù)、網(wǎng)站推廣。 獲取集群部署所需 Jar 包由于 Alink 可以通過 Java 和 Python 兩種方式提交,建議在集群部署的時候?qū)⑾嚓P(guān) Jar 包一起部署上去。Alink 雖然沒有單獨(dú)提供集群部署 Jar 包的下載,但是所需 Jar 包與 PyAlink 所用的相同。所以可以從 PyAlink 的安裝 whl 包中獲取。具體方式如下:
1.下載 PyAlink 1.10 的 whl 包,相關(guān)鏈接:
https://github.com/alibaba/Alink/releases/tag/v1.1.0
2.解壓 PyAlink 1.10 的 whl 包
解壓后的文件結(jié)構(gòu)如下圖所示,在 pyalink/lib 下為集群部署所需的三個 jar 包。
在 Standalone 集群上部署將前面獲取的三個 Jar 包拷貝到 Flink 目錄下,再啟動 Flink 集群即可。
在 Flink 配置中增加:classloader.resolve-order: parent-first 在 flink-[版本號]目錄下,運(yùn)行 bin/start-cluster.sh 啟動集群 bin/taskmanager.sh start 可以增加 TM