具有窗口 CoGroup 和未对齐检查点的 Flink 状态处理器 API

问题描述 投票:0回答:1
  1. 如何使用Flink State Processor API来处理窗口化CoGroup(或Join)函数的状态?文档没有给出这样的例子。
  2. 有没有办法使用Flink State Processor API来处理未对齐的检查点?
apache-flink flink-streaming stream-processing
1个回答
0
投票
  1. 不确定这是否可行。
  2. 不,这是不可能的。 (一般来说,在线串行器不需要与状态串行器相同。)

请参阅文档中的表格,显示检查点与保存点的功能和限制,了解有关状态处理器 API 的更多信息。

© www.soinside.com 2019 - 2024. All rights reserved.