如何在apache beam中使用flink runner执行检查点操作？

import apache_beam as beam

with beam.Pipeline(runner='FlinkRunner') as p:
    # 在这里定义你的数据处理逻辑
    ...

from apache_beam.runners.flink import flink_runner_checkpointing_options

with beam.Pipeline(runner='FlinkRunner') as p:
    # 配置Flink Runner的检查点选项
    p.options.view_as(flink_runner_checkpointing_options).checkpointing_interval = 10000  # 检查点间隔时间（毫秒）
    p.options.view_as(flink_runner_checkpointing_options).enable_externalized_checkpoints = True  # 启用外部化检查点

    # 在这里定义你的数据处理逻辑
    ...

from apache_beam.runners.flink import flink_runner_execution_options

with beam.Pipeline(runner='FlinkRunner') as p:
    # 配置Flink Runner的执行选项
    p.options.view_as(flink_runner_execution_options).parallelism = 4  # 设置并行度

    # 在这里定义你的数据处理逻辑
    ...

with beam.Pipeline(runner='FlinkRunner') as p:
    # 在这里定义你的数据处理逻辑
    ...
    result = p.run()
    result.wait_until_finish()