Flink Savepoint 和窗口操作答案

【问题标题】：Flink Savepoint and Window OperationFlink Savepoint 和窗口操作
【发布时间】：2022-11-16 23:35:58
【问题描述】：

下面是我用来测试检查点/保存点的示例 Flink 代码。

DataStream<Alarm> complexAlarmStream = alarmStream.keyBy(Alarm::getOntId)
.window(TumblingProcessingTimeWindows.of(Time.minutes(config                        .get(CheckPointTestingHighlevelFunctionParams.ONT_POWEROFF_DETECTION_WINDOW_TIME_IN_MIN))))
.process(new CheckPointTestingHighlevelFunction())
.uid("CheckPointTestingFunction").name("CheckPointTestingFunction");

这里的窗口是一个有状态的操作，它在 CheckPointTestingHighlevelFunctionParams.ONT_POWEROFF_DETECTION_WINDOW_TIME_IN_MIN中提到的时间内保存数据

如何为窗口函数提供 UID。

【问题讨论】：

标签： apache-flink

【解决方案1】：

您共享的代码正在为窗口操作员设置一个 UID。当你指定

.keyBy(...)
.window(...)
.allowedLateness(...)
.sideOutputLateData(...)
.process(...)
.uid("window-id").name("window-id")

所有这些都有助于窗口操作员的规范。

【讨论】：