DTStack/flinkStreamSQL

不支持blink 下的 开窗函数的 RANGE 写法

yujiayue0815 opened this issue · 1 comments

SELECT
itemID,
itemType,
onSellTime,
price,
MAX(price) OVER (
PARTITION BY itemType
ORDER BY onSellTime
RANGE BETWEEN INTERVAL '2' MINUTE preceding AND CURRENT ROW) AS maxPrice
FROM tmall_item;

a49a commented

FlinkX 1.12 没问题,你试试