快捷搜索: 王者荣耀 脱发

StreamX添加Flink引擎时对scala版本的映射选择

StreamX添加Flink引擎时,报如下错误:

Failed

The current Scala version of StreamX is 2.12.7, but the scala version 
of Flink to be added is 2.11, which does not match, Please check

原因分析:

由错误提示可以知道,StreamX运行时环境所使用的scala版本是2.12,而当前配置的Flink Standalone集群版本使用的scala版本为2.11,版本不一致,导致报错。

而由官方v1.2.3版本可知,其既支持scala-2.11版本,也支持scala-2.12版本:

解决方案:

StreamX 下载时,其编译时scala版本,需要与Flink编译时scala版本保持一致。

以 StreamX 的 v1.2.3版本为例,按以下对应关系进行安装:

StramX版本 Flink版本 streamx-console-service_2.11-1.2.3.tar.gz, flink-1.13.6-bin-scala_2.11.tgz , streamx-console-service_2.12-1.2.3.tar.gz, flink-1.13.6-bin-scala_2.12.tgz,

验证结果:

streamx-console-service_2.12-1.2.3,在配置flink-1.13.6-bin-scala_2.12的版本映射后,配置生效。

经验分享 程序员 微信小程序 职场和发展