flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Abdul Salam Shaikh <abd.salam.sha...@gmail.com>
Subject Re: Expected behaviour of windows
Date Mon, 23 Jan 2017 21:02:33 GMT
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(WindowCustomTrigger.java:51)
at
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator$Context.clear(WindowOperator.java:643)
at
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.cleanup(WindowOperator.java:421)
at
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.processElement(WindowOperator.java:321)
at
org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:185)
at
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:63)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:269)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:654)
at java.lang.Thread.run(Thread.java:745)

Do we have support for this functionality in *1.2-SNAPSHOT* ?

Thanks.

On Mon, Jan 23, 2017 at 10:57 AM, Jonas <jonas@huntun.de> wrote:

> 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 and keeps it as it
> > is, i.e., all elements remain in the window and are evaluated again when
> > the triggers fires the next time.
>
> So you can choose between *Fire*, *Purge* and *Fire&Purge*. Seems like
> selected *Fire* but meant to choose *Fire&Purge*.
>
> From what it seems you want a PurgingTrigger. You also didn't state what
> version of Flink you are using :)
>
> -- Jonas
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Expected-behaviour-of-windows-
> tp11200p11205.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>



-- 
Thanks & Regards,

*Abdul Salam Shaikh*

Mime
View raw message