如何将 Flink S3 sink Delivery mode 从 EXACTLY_ONCE 更新为 AT_LEAST_ONCE

Question

Flink S3 sink 默认以 EXACTLY_ONCE 交付模式写入。我想将它更新为 AT_LEAST_ONCE 模式。我找不到需要更新什么配置才能实现它。

从我们的工作结束，我们正在设置检查点配置 exactly_once。我不确定我是否将此检查点配置更新为 at_least 一次，它是否也会更新交付模式配置？

 env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE);

Answer 1

我相信，如果您使用（较新的）FileSink 写入 S3，您需要做的就是将检查点模式更改为 AT_LEAST_ONCE。

我不确定旧的 Flink 文件接收器是否有任何特定于 S3 的配置，但我认为没有，所以即使在那种情况下，您只需更改检查点模式就可以了。