Flink 源码解读系列 DataStream 时间服务管理器 TimeServiceManager 设计与实现

Posted 2022-09-20 @SmartSi

Flink 1.15.2

1. InternalTimeServiceManager 设计

Flink 1.12.0 版本将 InternalTimeServiceManager 重构为一个接口，目标是可以自定义实现不同的 InternalTimerService 实现，具体查阅FLINK-19288。当前版本下，InternalTimeServiceManager 提供了2个核心方法，一个是创建 InternalTimerService 实例的 getInternalTimerService，另一个就是通知所有 InternalTimerService 实例 Watermark 更新的 advanceWatermark：

@Internal
public interface InternalTimeServiceManager<K