15-flink-1.10.1-flink 状态后端

Posted 2023-02-19 逃跑的沙丁鱼

1 状态后端

保存状态有专门的一个组件来做。不需要我们额外开发

 2   选择一种方式的状态后端

需要根据自己的业务需要选择一种适合自己的状态后端方式

3 状态后端的设置

3.1 MemoryStateBackend

env.setStateBackend(new MemoryStateBackend()) // MemoryStateBackend

3.2 FsStateBackend

env.setStateBackend(new FsStateBackend("/date/stateDir"))//FsStateBackend

3.2 RocksDBStateBackend

① 引入第三方jar

<dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-statebackend-rocksdb_2.12</artifactId>
            <version>1.10.1</version>
        </dependency>

② 设置 

env.setStateBackend(new RocksDBStateBackend("checkpointDateUri"))//RocksDBStateBackend