hi, ????????, > GROUP BY TUMBLE(ts, INTERVAL '1' HOUR) ????source??????????[1],demo ??????jark wu ??[2],??????????app ????????kafka ??.
[1]"'scan.startup.mode'='earliest-offset'," [2]https://github.com/wuchong/flink-sql-demo/tree/v1.11-CN >> ????????????executeSql????????TableResult???????? .... wait job finished >??????????????????ide????????executeSql??????????????????????job?????????? ???????? tableResult.getJobClient() .get() .getJobExecutionResult(Thread.currentThread().getContextClassLoader()) .get(); ????,run ???????????????????????????????????????????????????????..????print sink ????????????
