Re: How to trigger the window function even there's no message input in this window?

Posted by Piotr Nowojski-3 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-many-task-managers-to-launch-for-a-job-tp27983p28289.html

Hi,

As far as I know, this is currently impossible.

You can workaround this issue by maybe implementing your own custom post processing operator/flatMap function, that would:

- track the output of window operator

- register processing time timer with some desired timeout

- every time the processing time timer fires, your code would check if window operator has emitted something in the last X seconds period. If not, it could emit some default element

Piotrek

On 14 Jun 2019, at 12:08, [hidden email] wrote:

windowAll(TumblingProcessingTimeWindows.of(Time.seconds(10))).process(new MyProcessWindowFunction());

How can i trigger the MyProcessWindowFunction even there's no input during this window time? 

---

[hidden email]