Hi > > bsTableEnv.executeSql("SELECT f_random, count(1) " + > "FROM datagen " + > "GROUP BY TUMBLE(ts, INTERVAL '1' second), f_random").print();
TableResult.print() 方法目前只支持了 exactly-once 语义,在 streaming 模式下必须设置checkpoint才能work, 你配置下checkpoint之后再试下,支持 At Least Once 的方法在1.12里应该会支持,支持后可以不用设置 checkpoint。 祝好 Leonard