RE: 回复：RE: EventTimeTrigger源码求帮忙解读，求各位大佬帮帮忙，不胜感激

谢回复~ 针对说的第三点，数据是乱序的，但是这个onelement方法处理的都是属于该window的数据,所以注册的都是当前window的maxTimeStamp，不会注册其他的window，不知道说的对不对。 -- 原始邮件 ------ 发件人: "Shi Quan"; 发送时间: 2019年6月24日(星期一) 中午11:07 收件人: "user-zh@flink.apache.org"; 主题: RE: EventTimeTrigger源码求帮忙解读，求各位大佬帮帮忙

RE: EventTimeTrigger源码求帮忙解读，求各位大佬帮帮忙，不胜感激

Hi, 这里是我之前对Window、State、Watermark三者关系的一个总结https://blog.csdn.net/xianzhen376/article/details/90415350 同时你的问题引发了新的思考，因为之前并没有关注onWaterMark的处理。简单的过了下源码后，我这里抛砖引玉几点： 1. registerEventTimeTimer 并不是注册定时器，是一个很轻量的实现，实际上是一个Queue，记录以namespace和key为索引的window.maxTimestamp，此处的window表示Element event

RE: Flink????Event Time????????????????????

??Flink??CEP??notFollowedBy??within?? Session

RE: ????: flink

OutputTag?? BTW??OutputTag?? Sent from Mail for Windows 10 From: deng Sent: Monday, May 13, 2019

RE: taskmanager faild

你好， 除了taskmanager的内存和网络，还可以关注jobmanager的GC等信息。 另外，之前有在想这个问题：Jm和Tm之间采用租约机制是不是更好？在高负载情况下，适当加长租约。 石权 From: naisili Yuan Sent: Tuesday, May 7, 2019 12:02:04 PM To: user-zh@flink.apache.org Subject: Re: taskmanager faild 好吧，这次我就不贴图了，我想问个问题，就是在使用flink

RE: Re:Re: 使用hdfs保存checkpoint一段时间后报错

Hi, 你对eventTime和窗口的分析很赞。 如果你的核心诉求是数据长时间中断情况下，希望不要丢弃处理老的数据。allowLateness应该能解决你的问题。 祝好 石权 Sent from Mail for Windows 10 From: 邵志鹏 Sent: Monday, May 6, 2019 10:05:37 AM To: user-zh@flink.apache.org

RE: Flink 状态使用问题咨询

嗯，明白你的意思，initTime < openTime是做何考虑，什么情况下initTime < openTime会满足 > 在 2019年4月24日，下午8:16，Shi Quan 写道： > > initTime < openTime

RE: Flink 状态使用问题咨询

有做过类似的事情，不用侵入flink的源码。记录几个关键信息： 1. Function open的时间，openTime； 2. 数据初始化的时间，initTime，可以用State保存； 3. 真正的业务State 当有数据过来时，iff (null == initTime) || (initTime < openTime) 进行初始数据加载动作。 Sent from Mail for Windows 10

RE: ??????RE: flink??????????????

newArrayList(elements); out.collect(OrderInfoArrayList); } } -- ---------- ??: "Shi Quan"; : 2019??4??23??(??) 10:02 ??: "user-zh

RE: flink??????????????

?? 1.

Re: 远程提交代码到Flink集群

Flink的ClassLoader就是普通的URLClassLoader，只是加载顺序是ChildFirst。 不建议你用直接更新classes文件去解决版本更新问题，因为你可能用了很大的力气去解决一个伪需求。 可以用脚本通过Flink提供的rest 接口来实现jar包上传等动作，甚至可以将CI和部署结合起来。 我曾今做过类似的事情，你可以参考下： https://blog.csdn.net/xianzhen376/article/details/88529527 On 2019/03/28 13:06:41, "文报" <1...@qq.com> wrote: > 各位好！> >