Flink1.15处理时间下如何正确设置CUMULATE窗口参数

这个问题是Flink 1.15版本的关键字冲突+时间属性校验规则共同导致的：

1. 关键字冲突问题：proctime是Flink SQL的内置保留字段名，框架默认会用这个名称做隐式处理时间属性的标记。当你手动显式定义proctime AS PROCTIME()时，会触发内置校验逻辑的冲突，导致该字段的「时间属性」元标记丢失，退化为普通的TIMESTAMP_LTZ类型值，因此窗口TVF（表值函数）识别不到合法的时间属性列，抛出类型不匹配错误。
2. 类型转换失效问题：Flink的时间属性（处理时间/事件时间）是绑定在原始列上的特殊元信息，只要你对该列做CAST、算术运算等任何加工转换，这个元标记就会被直接抹除，转换后的列只是普通的时间类型值，不满足窗口函数对时间属性列的强制要求，所以哪怕转成TIMESTAMP类型依然会报错。
3. 把列名改成pro_time后，避开了内置保留关键字的冲突，PROCTIME()函数生成的列会被正确打上处理时间属性的标记，因此可以正常通过校验。

• 命名处理时间属性列时，不要使用proctime、rowtime这类Flink内置的时间属性保留字，推荐使用proc_time、process_time等自定义命名，避免触发隐式逻辑冲突。
• 时间属性列定义完成后，不要对其做任何类型转换、计算加工，必须将原始的属性列直接传入CUMULATE的DESCRIPTOR()参数中，否则会丢失时间属性标记。
• CUMULATE窗口参数需严格按照顺序传入：第一个参数为输入表，第二个为时间属性列描述符，第三个为窗口累积步长，第四个为窗口最大长度，注意步长必须可以被最大窗口长度整除，否则会触发参数校验错误。

正确示例代码 #

源表定义：

CREATE TEMPORARY TABLE source_table (
    -- 此处省略其他业务字段
    proc_time AS PROCTIME() -- 自定义非保留字作为处理时间列名
);

CUMULATE窗口聚合逻辑：

CREATE TEMPORARY VIEW temp_view AS
SELECT
    window_start,
    window_end,
    -- 此处填写需要的聚合计算逻辑，如字段聚合、维度统计等
    COUNT(1) AS record_cnt
FROM TABLE(
    CUMULATE(
        TABLE source_table,
        DESCRIPTOR(proc_time), -- 直接传入未加工的处理时间属性列
        INTERVAL '1' MINUTES,  -- 配置窗口步长为1分钟
        INTERVAL '1' DAYS      -- 配置最大窗口长度为1天
    )
)
GROUP BY window_start, window_end;

内容的提问来源于stack exchange，提问作者Koike