insert into `test_out` select a.uid, 'dt', max(a.age) from `test_in` as a group 
by uid, cumulate(PROCTIME(), interval '1' minute, interval '1' hour);


hello, 各位大佬, flink 1.13.0 中流式作业中该怎么使用cumulate window呢?我用上面的SQL 貌似是不行, 
有没有使用过的大佬给点建议?




| |
邹云鹤
|
|
[email protected]
|
签名由网易邮箱大师定制

回复