Re: Error restoring from checkpoint on Flink 1.8

For clarification, one of the operators in the chain mentioned in the error message is a KeyedBroadcastProcessFunction, which I believe creates an InternalTimerService implicitly. That might be why "_timer_state" appears in this operator chain. However, it is still a mystery to me why it worked in

Error restoring from checkpoint on Flink 1.8

When testing a job on Flink 1.8, we hit the following error during resuming from RocksDB checkpoint. This job has been working well on Flink 1.6.1. The checkpoint was taken using the exact same job on 1.8. The operator StreamMap_3c5866a6cc097b462de842b2ef91910d it mentioned in the error message is

Re: Apache Flink - CEP vs SQL detecting patterns

Dawid: So, what happens when there is a timeout - is there any value/field in the resulting data stream that indicates that this was a timeout ? Thanks On Tuesday, April 16, 2019, 10:12:58 AM EDT, Dawid Wysakowicz wrote: Hi Mans, Yes you are right. That feature is not available i

status on FLINK-7129

Hi All, There seems to be a lot of interest for https://issues.apache.org/jira/browse/FLINK-7129 Any rough idea on the status of this issue? Thanks!