因為想用以下flink的ml功能，因此需要將flink升級到1.9.
修改pom文件版本后，代碼幾乎沒報錯，一陣高興，只有批處理的創建變了

創新互聯長期為近1000家客戶提供的網站建設服務，團隊從業經驗10年，關注不同地域、不同群體，并針對不同對象提供差異化的產品和服務；打造開放共贏平臺，與合作伙伴共同營造健康的互聯網生態環境。為臨朐企業提供專業的成都網站設計、成都網站建設，臨朐網站改版等技術服務。擁有十載豐富建站經驗和眾多成功案例,為您定制開發。

BatchTableEnvironment tableEnv = new BatchTableEnvironment(env, TableConfig.DEFAULT());
變為
BatchTableEnvironment tableEnv = BatchTableEnvironment.create(env, TableConfig.getDefault());

（代碼并沒有運行，希望也能順利運行）

獲取alink的源代碼

 git clone https://github.com/alibaba/Alink.git
 cd Alink && mvn -Dmaven.test.skip=true clean package shade:shade

因為alink在maven服務器上沒有，所以需要你上傳
alink_core-0.1-SNAPSHOT.jar 到本公司服務器上，在項目的根目錄下執行 mvn deploy 上傳至本公司的服務器上。

然后引入

<dependency>
        <groupId>com.alibaba.alink</groupId>
        <artifactId>alink_core</artifactId> 
        <version>0.1-SNAPSHOT</version>
</dependency>

接著導入ALSExample進入ide，然后可以研究第一個例子了

另外有需要云服務器可以了解下創新互聯cdcxhl.cn，海內外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業上云的綜合解決方案，具有“安全穩定、簡單易用、服務可用性高、性價比高”等特點與優勢，專為企業上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

網站題目：flink1.9升級&alink使用-創新互聯
當前網址：http://vcdvsql.cn/article14/cedpde.html

成都網站建設公司_創新互聯，為您提供微信小程序、建站公司、小程序開發、網站收錄、定制開發、ChatGPT

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯