Flink1.14 table api GroupBy Window Aggregation

2021-11-20 文章 guanyq
请大佬指导下: table api grooupbywindow,为什么输出是Empty set。 public class GroupByWindow { public static void main(String[] args) { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env); List lst

Flink1.14 table api GroupBy Window Aggregation

2021-11-20 文章 guanyq
请大佬指导下: table api grooupbywindow,为什么输出是Empty set。