我使用的是flinksqlapi，我有一个类似于
Table result2 = tableEnv.sqlQuery(
"SELECT user, SUM(amount) " +
"FROM Orders " +
"GROUP BY TUMBLE(proctime, INTERVAL '1' DAY), user"
);我可以启用“allowedlatenness”并将最新数据作为一个侧输出吗
我使用的是flinksqlapi，我有一个类似于
Table result2 = tableEnv.sqlQuery(
"SELECT user, SUM(amount) " +
"FROM Orders " +
"GROUP BY TUMBLE(proctime, INTERVAL '1' DAY), user"
);我可以启用“allowedlatenness”并将最新数据作为一个侧输出吗
1条答案
按热度按时间nnt7mjpx1#
flink sql（1.5.0版）尚不支持后期数据处理。最晚的一排刚刚被删除。