i have requirement not to reject events .. even if they are late(after maximum allowedness). So the way i achieve this but overriding Tumbling window class and update event time to last event time if the event is late and for identification attached additional column in db as (currentevent/msPerHour - eventtime/msPerHour)
currentevent is a class level variable in Tumbling window. My problem statement is, in case of full runtime crash, can flink recover tumblewindow state? if yes how? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/State-in-Custom-Tumble-Window-Class-tp13177.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
