在 Flink 集群部署 Alink,需要部署三個(gè) Jar 包(本文會(huì)有一個(gè)部分專門講述如何獲?。瑢?duì)于不同 Flink 集群環(huán)境,方式有些區(qū)別,本文主要討論 Standalone 集群和 Kubernetes 集群。
讓客戶滿意是我們工作的目標(biāo),不斷超越客戶的期望值來自于我們對(duì)這個(gè)行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡(jiǎn)單的方式提供給客戶,將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價(jià)值的長(zhǎng)期合作伙伴,公司提供的服務(wù)項(xiàng)目有:主機(jī)域名、網(wǎng)站空間、營(yíng)銷軟件、網(wǎng)站建設(shè)、柳城網(wǎng)站維護(hù)、網(wǎng)站推廣。 獲取集群部署所需 Jar 包由于 Alink 可以通過 Java 和 Python 兩種方式提交,建議在集群部署的時(shí)候?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 下為集群部署所需的三個(gè) jar 包。
在 Standalone 集群上部署將前面獲取的三個(gè) Jar 包拷貝到 Flink 目錄下,再啟動(dòng) Flink 集群即可。
在 Flink 配置中增加:classloader.resolve-order: parent-first 在 flink-[版本號(hào)]目錄下,運(yùn)行 bin/start-cluster.sh 啟動(dòng)集群 bin/taskmanager.sh start 可以增加 TM
分享題目:文本教你如何在Flink集群部署Alink
當(dāng)前網(wǎng)址:http://www.rwnh.cn/article26/cgsocg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供域名注冊(cè)、Google、靜態(tài)網(wǎng)站、網(wǎng)站策劃、網(wǎng)站設(shè)計(jì)公司、云服務(wù)器
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)