It was an exception because I had missed the clear() function within my
CustomTrigger.
It works as expected now. Thanks for all the help :)
On Tue, Jan 24, 2017 at 12:23 AM, Abdul Salam Shaikh <
abd.salam.sha...@gmail.com> wrote:
> This is my definiton of the trigger for more clarity into the is
This is my definiton of the trigger for more clarity into the issue I am
running:
@Override
public TriggerResult onElement(FlatObject t, long l, Window w,
TriggerContext tc) throws Exception {
long currentTimeInCycle = t.getCurrentTimeInCycle();
if (lastKnownCurrentTimeInCycle
Thank you Jonas, I am using version *1.2-SNAPSHOT* of Apache Flink to
leverage the advanced Evictor class.
However, while trying to use FIRE_AND_PURGE I am getting the following
error:
java.lang.UnsupportedOperationException: Not supported yet.
at
de.traffic.ui.streaming.WindowCustomTrigger.clear
The documentation says
https://flink.apache.org/news/2015/12/04/Introducing-windows.html wrote
> On each event, a trigger can decide to fire (i.e., evaluate), purge
> (remove the window and discard its content), or fire and then purge the
> window. A trigger that just fires evaluates the window an
