flink-on-k8s的application模式怎么保存点重启大佬们有经验的吗 ，任务stop

在Flink on Kubernetes中，可以使用Savepoints来保存Flink应用程序的状态，以便在重启后可以从上一次的状态继续执行。

1、在Flink应用程序中添加代码来触发保存点的创建。

env.enableCheckpointing(checkpointInterval);
env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);
env.getCheckpointConfig().setCheckpointTimeout(checkpointTimeout);
env.getCheckpointConfig().setMaxConcurrentCheckpoints(maxConcurrentCheckpoints);
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(minPauseBetweenCheckpoints);
env.getCheckpointConfig().setPreferCheckpointForRecovery(preferCheckpointForRecovery);
env.getCheckpointConfig().setTolerableCheckpointFailureNumber(tolerableCheckpointFailureNumber);

2、在Flink on Kubernetes中配置Savepoints

spec:
  template:
    spec:
      containers:
      - name: taskmanager
        env:
        - name: FLINK_SAVEPOINTS_DIRECTORY
          value: "s3://your-bucket-name/savepoints/"
        - name: FLINK_SAVEPOINT_MODE
          value: "EXTERNALIZED"

3、在重启应用程序时，可以使用以下命令来加载Savepoints：

./bin/flink run -s s3://your-bucket-name/savepoints/your-savepoint-file-name

通过restful或者KubernetesClusterDescriptor去触发savepoint 启动任务的时候SavepointConfigOptions.SAVEPOINT_PATH设置到flinkconf中就行。

此答案来自钉钉群“【2】Apache Flink China 社区”

可以查看如何原生的在 K8s 上运行 Flink https://developer.aliyun.com/article/766710