flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vinay Patil <vinay18.pa...@gmail.com>
Subject Regarding Late Elements
Date Mon, 03 Oct 2016 03:21:34 GMT
Hi Guys,

Just wanted to get an idea on Why Flink decided to completely discard late
elements in the latest version ?, this was not the case in 1.0.3

P.S In our case the data is critical so we cannot discard a single record
even if it is late, I have written a custom trigger (as suggested by
Aljoscha) to even accept late elements.

Vinay Patil

View raw message