安装OmniStateStore
- 请参见表3获取软件包omnistatestore_1.1.0_aarch64_release.tar.gz。
- 登录安装节点,并上传软件包BoostKit-omnistatestore_1.1.0_aarch64_release.tar.gz至“${FLINK_HOME}/lib/”子目录下。
- 解压软件包。
tar -zxvf BoostKit-omnistatestore_1.1.0_aarch64_release.tar.gz
软件包里只有OmniStateStore对应的插件JAR包:
- flink-boost-statebackend-1.1.0-SNAPSHOT-for-flink-1.16.1.jar
- flink-boost-statebackend-1.1.0-SNAPSHOT-for-flink-1.16.3.jar
- flink-boost-statebackend-1.1.0-SNAPSHOT-for-flink-1.17.1.jar
只保留与当前Flink版本对应的JAR包,移除其他JAR包。当前以保留Flink 1.16.3版本为例。
rm -f flink-boost-statebackend-1.1.0-SNAPSHOT-for-flink-1.17.1.jar rm -f flink-boost-statebackend-1.1.0-SNAPSHOT-for-flink-1.16.1.jar
- 为了不占用磁盘空间,请执行以下命令删除软件包。
rm -f BoostKit-omnistatestore_1.1.0_aarch64_release.tar.gz
父主题: OmniStateStore状态优化