We have the same requirement - we cannot discard any data even if it arrives
late.
- LF
From: Vinay Patil <vinay18.pa...@gmail.com>
To: user@flink.apache.org
Sent: Sunday, October 2, 2016 8:21 PM
Subject: Regarding Late Elements
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.
Regards,Vinay Patil
