鲲鹏社区首页
中文
注册
开发者
我要评分
获取效率
正确性
完整性
易理解
在线提单
论坛求助

安装OmniStateStore

  1. 请参见表3获取软件包omnistatestore_1.1.0_aarch64_release.tar.gz。
  2. 登录安装节点,并上传软件包BoostKit-omnistatestore_1.1.0_aarch64_release.tar.gz至“${FLINK_HOME}/lib/”子目录下。
  3. 解压软件包。
    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
  4. 为了不占用磁盘空间,请执行以下命令删除软件包。
    rm -f BoostKit-omnistatestore_1.1.0_aarch64_release.tar.gz