我们从一个按键的窗口(由一个会话/设备令牌键控)中分割出一个的页面视图输入。该应用程序在小规模上运行良好,但当扩展到我们预期的正常生产吞吐量(每天大约100万页浏览量)进行测试时,我们在合并窗口时会周期性地遇到错误:
“The end timestamp of an event-time这个UnsupportedOperationException正在破坏我们的应用程序,当它重新启动时,它试图一次又一次地处理同一个窗口,然后一次又一次地崩溃。ActivitySessionAssigner.withGap(Time.minutes(
需要使用滑动窗口连接流。在连接和窗口数据时,我将得到一个错误Rowtime attributes must not be in the input rows of a regular join.TIMESTAMPDIFF(SECOND, ep.event_flink_time, cep.event_flink_time) as timediff,
HOP_START (cep.event_flink_time, INTERVAL '5' MINUTES, INTERVAL
: org.apache.flink.util.StateMigrationException: State migration is currently not supported.at org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.create(HeapKeyedStateBackend.java:216):121)
at org.apache.flink.streaming.api.operators.InternalTimeServiceManager.r