安装OmniStateStore
安装OmniStateStore
- 登录至安装节点,并上传软件包BoostKit-booststatestore_1.0.0.tar.gz至“${FLINK_HOME}/lib/”子目录下。
- 解压软件包。
tar -zxvf BoostKit-booststatestore_1.0.0.tar.gz
软件包里只有OmniStateStore对应的插件JAR包:
- flink-boost-statebackend-1.0.0-SNAPSHOT-for-flink-1.16.3.jar
- flink-boost-statebackend-1.0.0-SNAPSHOT-for-flink-1.17.1.jar
只保留与当前Flink版本对应的JAR包,移除其他JAR包。当前以保留Flink 1.16.3版本为例。
rm -f flink-boost-statebackend-1.0.0-SNAPSHOT-for-flink-1.17.1.jar
- 删除软件包。
rm -f BoostKit-booststatestore_1.0.0.tar.gz
父主题: OmniStateStore状态优化