flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From <lg...@yahoo.com>
Subject Re: Regarding Late Elements
Date Mon, 03 Oct 2016 15:05:31 GMT
We have the same requirement - we cannot discard any data even if it arrives late. 
- LF
 



      From: Vinay Patil <vinay18.patil@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

   
Mime
View raw message