flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 王佩 <wang...@cmcm.com>
Subject Re: 回复:Flink 消费Kafka Window不触发计算
Date Tue, 22 Oct 2019 04:34:25 GMT
把 Kafka Source 标记为 Idling source,有地方可以设置吗。没找到这个入口。

Utopia <gejunwei110@gmail.com> 于2019年10月21日周一 下午2:58写道:

> 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