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
windowAll(TumblingProcessingTimeWindows.of(Time.seconds(10))).process(new
MyProcessWindowFunction());How can i trigger the MyProcessWindowFunction even
there's no input during this window time?
wangl...@geekplus.com.cn