0

我们正在使用 Kinesis for Apache Flink 来分析来自多个来源的各种访问者事件。在其中一个运算符中,我们使用 MapSate 进行累积指标计算。Flink 应用程序在一周执行期间自动缩放 4 次。问题是每次自动缩放操作员状态都被完全丢弃。日志中没有错误消息,除了 - “收到信号 15:SIGTERM。按要求关闭。” 来自 TaskManagerRunner。

该作业使用以下配置: 检查点配置使用 DEFAULT 模式并已启用。应用程序自动缩放已启用。应用程序恢复配置 - 不带快照更新。状态不使用 TTL。

红线 KPU 蓝线正常运行时间

我的理解是否正确,如果我们需要在自动缩放后保持状态,我们应该使用 RESTORE_FROM_LATEST_SNAPSHOT 配置开始工作?我认为只有完整的应用程序重新启动才需要这个值。还有其他可能导致类似问题的东西吗?

4

0 回答 0