4848
4949 - PyAlink 根据 Alink 所支持的 Flink 版本提供不同的 Python 包:
5050其中,` pyalink ` 包对应为 Alink 所支持的最新 Flink 版本,当前为 1.13,而 ` pyalink-flink-*** ` 为旧版本的 Flink 版本,当前提供 ` pyalink-flink-1.12 ` , ` pyalink-flink-1.11 ` , ` pyalink-flink-1.10 ` 和 ` pyalink-flink-1.9 ` 。
51- - Python 包的版本号与 Alink 的版本号一致,例如` 1.5.4 ` 。
51+ - Python 包的版本号与 Alink 的版本号一致,例如` 1.5.5 ` 。
5252
5353####安装步骤:
54541 . 确保使用环境中有Python3,版本限于 3.6,3.7 和 3.8。
61611 . ` pyalink ` 和 ` pyalink-flink-*** ` 不能同时安装,也不能与旧版本同时安装。
6262如果之前安装过 ` pyalink ` 或者 ` pyalink-flink-*** ` ,请使用` pip uninstall pyalink ` 或者 ` pip uninstall pyalink-flink-*** ` 卸载之前的版本。
63632 . 出现` pip ` 安装缓慢或不成功的情况,可以参考[ 这篇文章] ( https://segmentfault.com/a/1190000006111096 ) 修改pip源,或者直接使用下面的链接下载 whl 包,然后使用 ` pip ` 安装:
64- - Flink 1.13:[ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.4 /pyalink-1.5.4 -py3-none-any.whl ) (MD5: a68fa2474bc52dc2181bc98787d3e2d3 )
65- - Flink 1.12:[ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.4 /pyalink_flink_1.12-1.5.4 -py3-none-any.whl ) (MD5: ed191adfd5bbaaacf979aa373a7a61f5 )
66- - Flink 1.11:[ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.4 /pyalink_flink_1.11-1.5.4 -py3-none-any.whl ) (MD5: 8d4fae4e23e9198ea770b718404ef7e6 )
67- - Flink 1.10:[ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.4 /pyalink_flink_1.10-1.5.4 -py3-none-any.whl ) (MD5: c24a14496b873ea4c8048bbd83061c1f )
68- - Flink 1.9: [ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.4 /pyalink_flink_1.9-1.5.4 -py3-none-any.whl ) (MD5: 878bc39a15eb22e4c67eb21d8bf9a337 )
64+ - Flink 1.13:[ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.5 /pyalink-1.5.5 -py3-none-any.whl ) (MD5: 4d6ebc65eadebf68835c9834d30f2e17 )
65+ - Flink 1.12:[ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.5 /pyalink_flink_1.12-1.5.5 -py3-none-any.whl ) (MD5: b7ab1a4d99837af70fd0902b86b5806f )
66+ - Flink 1.11:[ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.5 /pyalink_flink_1.11-1.5.5 -py3-none-any.whl ) (MD5: 2ff6b9836be67be484e8a7fe961d7307 )
67+ - Flink 1.10:[ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.5 /pyalink_flink_1.10-1.5.5 -py3-none-any.whl ) (MD5: 8a26eef0a664b0bc1a6a70215c7c8f05 )
68+ - Flink 1.9: [ 链接] ( https://alink-release.oss-cn-beijing.aliyuncs.com/v1.5.5 /pyalink_flink_1.9-1.5.5 -py3-none-any.whl ) (MD5: a75ab7f0212cb1ae0886e7d38fc9e713 )
69693 . 如果有多个版本的 Python,可能需要使用特定版本的 ` pip ` ,比如 ` pip3 ` ;如果使用 Anaconda,则需要在 Anaconda 命令行中进行安装。
7070
7171#### 下载安装文件系统或 Catalog 依赖 jar 包:
@@ -160,7 +160,7 @@ pipeline.fit(data).transform(data).print();
160160<dependency >
161161 <groupId >com.alibaba.alink</groupId >
162162 <artifactId >alink_core_flink-1.13_2.11</artifactId >
163- <version >1.5.4 </version >
163+ <version >1.5.5 </version >
164164</dependency >
165165<dependency >
166166 <groupId >org.apache.flink</groupId >
@@ -184,7 +184,7 @@ pipeline.fit(data).transform(data).print();
184184<dependency >
185185 <groupId >com.alibaba.alink</groupId >
186186 <artifactId >alink_core_flink-1.12_2.11</artifactId >
187- <version >1.5.4 </version >
187+ <version >1.5.5 </version >
188188</dependency >
189189<dependency >
190190 <groupId >org.apache.flink</groupId >
@@ -208,7 +208,7 @@ pipeline.fit(data).transform(data).print();
208208<dependency >
209209 <groupId >com.alibaba.alink</groupId >
210210 <artifactId >alink_core_flink-1.11_2.11</artifactId >
211- <version >1.5.4 </version >
211+ <version >1.5.5 </version >
212212</dependency >
213213<dependency >
214214 <groupId >org.apache.flink</groupId >
@@ -232,7 +232,7 @@ pipeline.fit(data).transform(data).print();
232232<dependency >
233233 <groupId >com.alibaba.alink</groupId >
234234 <artifactId >alink_core_flink-1.10_2.11</artifactId >
235- <version >1.5.4 </version >
235+ <version >1.5.5 </version >
236236</dependency >
237237<dependency >
238238 <groupId >org.apache.flink</groupId >
@@ -252,7 +252,7 @@ pipeline.fit(data).transform(data).print();
252252<dependency >
253253 <groupId >com.alibaba.alink</groupId >
254254 <artifactId >alink_core_flink-1.9_2.11</artifactId >
255- <version >1.5.4 </version >
255+ <version >1.5.5 </version >
256256</dependency >
257257<dependency >
258258 <groupId >org.apache.flink</groupId >
0 commit comments