安装OmniStateStore
- 请参见表3获取软件包BoostKit-omniruntime-omnistatestore-1.1.0.zip。
- 登录安装节点,并上传软件包BoostKit-omniruntime-omnistatestore-1.1.0.zip至“${FLINK_HOME}/lib/”子目录下。
- 解压软件包。
unzip BoostKit-omniruntime-omnistatestore-1.1.0.zip tar -zxvf BoostKit-omniruntime-omnistatestore-1.1.0.tar.gz
- 将Flink版本对应的JAR包复制到“${FLINK_HOME}/lib/”目录。
以1.16.3版本为例。
cp BoostKit-omnistatestore_1.1.0/java/jars/flink-boost-statebackend-1.1.0-SNAPSHOT-for-flink-1.16.3.jar ./
- 为了不占用磁盘空间,请执行以下命令删除软件包。
rm -f BoostKit-omniruntime-omnistatestore-1.1.0.tar.gz rm -f BoostKit-omniruntime-omnistatestore-1.1.0.zip rm -rf BoostKit-omnistatestore_1.1.0/
父主题: OmniStateStore状态优化