0

我一般理解事件时间使用水印及时取得进展。对于更多基于迭代的 Flink Statefun 来说,这可能是个问题。所以我的问题是如果我使用延迟消息(https://nightlies.apache.org/flink/flink-statefun-docs-stable/docs/sdk/java/#sending-delayed-messages),那么这是否意味着我们可以在有状态函数中仅使用处理时间概念吗?

我想更改为事件时间处理模型,但不确定它如何与有状态函数一起使用。

pipeline.time-characteristic: EventTime
pipeline.auto-watermark-interval: 200

有人可以解释一下吗?

4

1 回答 1

0

有状态函数 (statefun) 不支持水印或事件时间处理。但是您可以根据到达事件中的时间戳实现自己的触发逻辑。

于 2022-02-03T09:06:12.657 回答