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

回复