---
title: 启动OmniStateStore
description: "1. 配置安装信息。"
url: https://www.hikunpeng.com/document/detail/zh/kunpengboostkithistory/251RC1/bds/kunpengbds_omniruntime_20_1012.html
sourcePath: /source/zh/kunpengboostkithistory/251RC1/bds/kunpengbds_omniruntime_20_1012.html
indexId: db3d26833d400edad1b8469cda563651bcf43775f92ab1cb0dc6fe99216f8d3880
---
# 启动OmniStateStore

1. 配置安装信息。
  根据业务使用情况和待安装部署的环境设置Flink的conf子目录下flink-conf.yaml中的相关配置项，OmniStateStore相关配置项说明参考表1 OmniStateStore配置项。

  以下为使能OmniStateStore特性必须要在${FLINK_HOME}/conf/flink-conf.yaml中新增或修改的配置项，需要在Job Manager和所有Task Manager的配置文件中同时修改。

**表1 同步配置项说明**

| 配置项名称 | 简要描述 | 配置示例 | 注意事项 |
| --- | --- | --- | --- |
| state.backend | Flink开源参数，用于配置state.backend状态后端。 | com.huawei.ock.bss.OckDBStateBackendFactory | 此配置用于切换状态后端的类型，需要保证字符完全正确并区分大小写。 |
| state.backend.ockdb.localdir | OmniStateStore状态数据本地存储路径。 | “/usr/local/flink/ockdb” | 保证路径已存在且对Flink运行用户有读写权限。 |
| state.backend.ockdb.jni.logfile | OmniStateStore日志路径。 | “/usr/local/flink/log/kv.log” | 建议配置为Flink的日志目录。 |


  配置项格式：${配置项名称} + ${英文冒号} + ${空格} + ${配置项值}，如图1所示。

  图1 配置项示例

2. 启用MapState迭代器优化特性（可选）。
  Flink框架针对Join算子（JoinRecordStateViews）和TOPN算子（AppendOnlyTopNFunction）的状态访问机制进行优化，通过将业务算子对MapState迭代器的遍历访问重构为直接调用ValueState的get接口及MapState的精准键值查询，实现状态访问路径从“全量遍历”到“精准定位”的升级，有效降低状态管理开销。 由于存储的状态类型发生了变化，因此在启用MapState迭代器优化特性场景下，不支持通过Savepoint在OmniStateStore和其它类型的状态后端之间迁移状态数据。 如果运行的Flink业务不包含相关算子逻辑或者用户使用自定义的算子，也不支持使能此优化特性。

  JAR包名称为flink-boost-statebackend-1.0.0-SNAPSHOT-for-flink-${flink.version}.jar 。示例中以1.16.3版本为例。
  a. 在Task Manager的“${FLINK_HOME}/conf/flink-conf.yaml”配置文件中增加以下配置。

```
env.java.opts: -javaagent:$FLINK_LIB_DIR/flink-boost-statebackend-1.0.0-SNAPSHOT-for-flink-1.16.3.jar
```


  b. 在Job Manager的“${FLINK_HOME}/conf/flink-conf.yaml”配置文件中增加以下配置。

```
env.java.opts: -javaagent:$FLINK_LIB_DIR/flink-boost-statebackend-1.0.0-SNAPSHOT-for-flink-1.16.3.jar
```


  c. 在Job Manager的“${FLINK_HOME}/bin/sql-client.sh”脚本中增加以下启动参数。

```
-javaagent:$FLINK_LIB_DIR/flink-boost-statebackend-1.0.0-SNAPSHOT-for-flink-1.16.3.jar
```


    参考图2，将该参数添加到脚本中elif分支中的exec命令行。

    图2 exec命令行示例


3. 启动Flink任务，查看日志中的配置项，检查配置是否成功。
4. 执行“${FLINK_HOME}/examples/streaming/WordCount.jar”示例程序，观察到Task Manager日志中打印“OmniStateStore service start success.”，说明OmniStateStore启动成功。