flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Utopia <gejunwei...@gmail.com>
Subject Re: 回复:Flink 消费Kafka Window不触发计算
Date Mon, 21 Oct 2019 06:57:37 GMT
idling sources 只能解决 Kafka 没有数据的问题,如果是在业务逻辑里长时间没有收到某个用户新的数据呢?我想到的一个解决方法是接收到数据时在
Trigger 的 onElement 方法中注册一个 ProcessingTimer 用来触发 Window 计算,后续有新的数据就删除之前的
ProcessingTimer.
2019年10月21日 +0800 01:38 Ever <439674061@qq.com>,写道:
> 参考下:
> https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/event_time.html
>
> idling sources的说明
>
> <>
>
>
> ------------------ 原始邮件 ------------------
> 发件人: "王佩"<wangpei@cmcm.com>;
> 发送时间: 2019年10月20日(星期天) 上午10:38
> 收件人: "user-zh"<user-zh@flink.apache.org>;
> 主题: Flink 消费Kafka Window不触发计算
>
> Flink 消费Kafka, 有的并发没数据,导致Watermark不更新,进而Window不触发计算。
>
> 请教下:
>
>     像这种情况,一般解决方式有那些?
>
> 感谢!

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message