flink 状态存储至minio

可以通过 Flink 的 StateBackend 将状态存储至 MinIO。

具体步骤如下：

1. 在 Flink 配置文件中设置 StateBackend：

state.backend: filesystem
state.backend.fs.checkpointdir: s3a://minio-host:port/flink-checkpoints
state.backend.fs.hadoopconf: core-site.xml

2. 在 Flink 作业中使用 StateBackend：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StateBackend stateBackend = new FsStateBackend("s3a://minio-host:port/flink-checkpoints");
env.setStateBackend(stateBackend);

// 设置 Checkpoint 相关参数
env.enableCheckpointing(10000);
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(500);
env.getCheckpointConfig().setCheckpointTimeout(60000);
env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);

注意：需要将 MinIO 的访问密钥和访问密钥 ID 配置到 Flink 的 Hadoop 配置文件中，以便可以访问 MinIO 存储桶中的数据。