Flink - 异步窗口

Question

这是一个关于 flink 流的两个问题主题，基于我自己做的实验，我需要澄清一下。问题是：

1. 当我们在 flink 的 KeyedStream 上使用 windows 时，apply 函数的计算是异步的吗？具体来说，flink 是否会为每个键创建单独的窗口，并相互独立地处理这些窗口？

2. 假设我们在一个窗口流上使用 apply 函数（做一些计算），然后创建一个 DataStream。如果我们对生成的 DataStream 进行一些转换，flink 会将整个 WindowedStream 保存在内存中吗？并且 flink 会等到 WindowedStream 的所有 apply 函数都完成后再继续对结果流进行转换吗？

在我所做的所有实验中，我都使用了事件时间并从文件中读取数据。我在实验中观察到了上述陈述，我需要澄清一下。

Answer 1

广告。 1 是的，每个密钥都是独立处理的。这也是 windows 计算并行化的方式。

Ad.2 Flink 将保持窗口状态，直到可以发出窗口（加上一些额外的时间，以防allowedLateness）。一旦窗口的结果被发出（在你的情况下被转发给下一个操作员），状态就可以被清除。