启动OmniStateStore

本章节介绍如何启动OmniStateStore服务，以启用Flink状态存储的加速功能。

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

   配置项格式为${配置项名称} + ${英文冒号} + ${空格} + ${配置项值}。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的日志目录。

     配置项示例如下所示。

     state.backend: com.huawei.ock.bss.OckDBStateBackendFactory
     state.backend.ockdb.localdir: /usr/local/flink/ockdb
     state.backend.ockdb.jni.logfile: /usr/local/flink/log/kv.log

   • 开启Priority Queue持久化存储

     配置项示例如下所示。

     state.backend.ockdb.timer-service.factory: OCKDB

   • 开启KV分离存储

     配置项示例如下所示。

     state.backend.ockdb.kv-separate.switch: true
     state.backend.ockdb.kv-separate.threshold: 200

2. 执行以下命令，创建必要的目录。
   示例中，state.backend.ockdb.localdir配置为“/usr/local/flink/ockdb”，state.backend.ockdb.checkpoint.backup配置为“/usr/local/flink/checkpoint/backup”，安装时请以实际配置为准。

   mkdir -p /usr/local/flink/ockdb
   mkdir -p /usr/local/flink/checkpoint/backup

3. 启动Flink任务，查看日志中的配置项，检查配置是否成功。
4. 执行“${FLINK_HOME}/examples/streaming/WordCount.jar”示例应用程序。

   观察到Task Manager日志中打印“OmniStateStore service start success.”，说明OmniStateStore启动成功。