Hi, 在 1.14.0 版本中，CUMULATE 函数是需要用在GROUP BY聚合场景下的[1]。 部署到生产的 SQL 是否包含了 GROUP BY 表达式？ 本地测试的Flink版本是不是1.14.0?
Best, Jiabao [1] https://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/dev/table/sql/queries/window-tvf/#cumulate On 2023/12/29 04:57:09 "jiaot...@mail.jj.cn" wrote: > Hi， > 我在使用1.14.0版本Flink，本地测试了CUMULATE(TABLE kafka, DESCRIPTOR(rowtime), > INTERVAL '60' SECOND, INTERVAL '1' DAYS)方法可以正常运行，但是当我将其部署到线上环境报了如下错误： > org.apache.flink.client.program.ProgramInvocationException: The main > method caused an error: Currently Flink doesn't support individual window > table-valued function CUMULATE(time_col=[rowtime], max_size=[86400000 ms], > step=[1 min]). > Please use window table-valued function with the following computations: > 1. aggregate using window_start and window_end as group keys. > 2. topN using window_start and window_end as partition key. > 3. join with join condition contains window starts equality of input > tables and window ends equality of input tables. > 请问这是因为线上包版本导致的吗，如果是版本问题，具体是哪一个包呢 > 非常感谢 >
