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
