Hi!
Window aggregations will only output results when the watermark rises above
the end of window. Let's say the end of window is at 00:01, only
when recvdTime is larger or equal than 00:06 will this window emit (because
there is a 5 minutes out of orderness).
If it is not the case then it indeed
Hi Team,
I am trying to upgrade from 1.7 to 1.13
Code in 1.7
Schema schema = new Schema();
schema.rowtime(new Rowtime()
.timestampsFromField("eventTime")
.watermarksPeriodicBounded(3000)
);
Code in 1.13
tableEnv.executeSql("CREATE TABLE ORDERS ( " +
"`sid` BIGINT, " +
