Flink1.14 table api GroupBy Window Aggregation
请大佬指导下: 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
请大佬指导下: table api grooupbywindow,为什么输出是Empty set。