flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 王志明 <wangzmk...@163.com>
Subject Re:Re:Flink基于Event Time的长时间数据延迟问题
Date Tue, 11 Jun 2019 04:42:45 GMT
Hi,保淇:
       请问能否分享 “Flink 在滴滴运用” 的PDF?








在 2019-05-30 09:21:13,"张保淇" <hzuzhangbaoqi@163.com> 写道:
>
>
>建议使用CEP复杂时间处理机制,匹配两个时间发生的时间点,你可以看看Flink
在滴滴运用,里面就提及到CEP,跟你的业务场景很匹配,如果方便,麻烦发下我使用CEP后的测试情况,谢谢!
>
>
>
>
>在 2019-05-28 11:30:28,"690963922" <zhang_moly@qq.com> 写道:
>
>尊敬的Flink Committer大神好:
>
>
>      最近我们公司使用Flink框架做实时计算,有这样一个场景困扰着我们。情况描述如下:
>
>
>      我们希望通过实时计算用户的浏览行为,在该用户浏览某页面15分钟后,没有继续浏览该页面,就给用户推送消息。目前遇到的问题是,我们的用户量不大,在凌晨02:00到04:00之间基本没有用户的日志。
>
>
>      我们使用的是Flink 提供的Session Window,设置的GapTime是15分钟。如上所述,我们的代码在凌晨02:00到04:00之间,没有用户相关的数据流入,导致Session
Window无法触发。不能计算出在02:00之前的15分钟的用户数据。我们希望是,即使在02:00到04:00没有用户浏览行为,也可以将之前在Session
Window的数据进行触发计算。请问有什么办法,可以解决这个问题吗?
>
>
>      下面是我们的代码:见附件
>
>
>      期待大神的回复
>
>
>                                                                                     
                                                                 
>
>
>
>
>                                                                                     
                                                                                         
                                                  张智强  
>                                                                                     
                                                                                         
                                               
>                                                                                     
                                                                                         
                                                  2019年05月28日
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message