Hi, longfent. We could use `withIdleness`[1] to deal with the idle sources.
Best, Hang [1] https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/datastream/event-time/generating_watermarks/#dealing-with-idle-sources longfeng Xu <xulongfeng2...@gmail.com> 于2023年8月27日周日 14:01写道： > Hello, > > The issue I’m encountering revolves about > 1、 aggregating products sales for each minute. Sale data from Kafka with > eventtime. > 2、If there is no data in that minute, program should produces default zero. > 3、all time I mention are eventtime. No using process time is consider of > rerun situation. > 4、when using flink eventTimeWindow function, process function can not be > trigger if no event input at that window. > > For example, a product named A which have two data input with time > 9:25:12 and 9:28:23 ,how can I output zero between 9:25 and 9:28 with > EventTime window? > > Best regards, > Xlf >
