配置flink的checkpoint用minio存储 如何完整的配置步骤及参数

要将 Flink 的 checkpoint 存储在 MinIO 中，你需要进行以下步骤：

1. 在 MinIO 上创建桶

在 MinIO 上创建一个桶用于存储 Flink 的 checkpoint。

2. 添加 Maven 依赖

你需要在你的 Flink 项目中添加以下 Maven 依赖：

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-s3-fs-hadoop</artifactId>
  <version>${flink.version}</version>
</dependency>

其中 `${flink.version}` 是你正在使用的 Flink 版本号。

3. 配置 checkpoint

在你的 Flink 项目中，你需要在 `flink-conf.yaml` 文件中进行以下配置：

state.backend: filesystem
state.checkpoints.dir: s3a://<bucket-name>/<path>
state.savepoints.dir: s3a://<bucket-name>/<path>

其中 `<bucket-name>` 是你在 MinIO 上创建的桶的名称，`<path>` 是你希望存储 checkpoint 的路径。

4. 配置 MinIO 认证信息

在 `core-site.xml` 文件中，你需要添加以下配置：

<configuration>
  <property>
    <name>fs.s3a.access.key</name>
    <value>ACCESS_KEY</value>
  </property>
  <property>
    <name>fs.s3a.secret.key</name>
    <value>SECRET_KEY</value>
  </property>
  <property>
    <name>fs.s3a.endpoint</name>
    <value>http://MINIO_HOST:9000</value>
  </property>
</configuration>

其中 `ACCESS_KEY` 和 `SECRET_KEY` 是你的 MinIO 认证信息，`MINIO_HOST` 是你的 MinIO 服务器地址。

现在你已经完成了将 Flink 的 checkpoint 存储在 MinIO 中的配置。在启动你的 Flink 应用程序时，Flink 将会自动将 checkpoint 存储在 MinIO 中。