flinksql中窗口上的最后一个\u值

vs91vp4v  于 2021-06-26  发布在  Flink
关注(0)|答案(0)|浏览(349)

我想运行以下查询

SELECT key, LAST_VALUE(value) OVER (PARTITION BY key ORDER BY ts) AS value
  FROM [table]
 GROUP BY key, TUMBLE(ts, INTERVAL '5' MINUTE)

我希望如此 LAST_VALUE 将返回每个时间窗口的最后一个值。相反,我得到了

Expression 'value' is not being grouped

有什么办法解决吗?
编辑1:尝试了类似

SELECT key, LAST_VALUE(value) OVER (PARTITION BY key, TUMBLE(ts, INTERVAL '5' MINUTE) ORDER BY ts) AS value
  FROM [table]

但是我得到了

Unsupported call: TUMBLE(TIMESTAMP(3) *ROWTIME*, INTERVAL SECOND(3) NOT NULL)

(另外:我认为这并不等同于现在我可能得到的是retract stream而不是append stream)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题