Flink Table滚动窗口创建报错：Expected LocalReferenceExpression. Got: EventTime

错误原因 #

你在定义滚动窗口时混用了事件时间字段和处理时间属性生成方法，这是核心问题：$("EventTime").proctime()属于非法用法——proctime()是用来从系统处理时间生成时间属性的方法，而EventTime已经是你转换后的Timestamp类型字段，直接用它定义事件时间窗口即可，不需要额外调用proctime()。这种混用导致Flink无法正确解析窗口的时间属性，进而抛出类型不匹配的错误。

解决步骤 #

1. 修正窗口时间属性定义：移除proctime()调用，直接使用EventTime作为窗口的时间字段。
2. 标记EventTime为事件时间属性：如果EventTime只是普通Timestamp字段，需要用.rowtime()将其标记为事件时间属性（Flink需要明确的时间属性来处理窗口逻辑）。

修正后的代码 #

Table table = tEnv.sqlQuery(query.getQuery());
// 将字符串类型的EventTimestamp转换为Timestamp，并标记为事件时间属性
table = table.addColumns($("EventTimestamp").toTimestamp().rowtime().as("EventTime"));
// 基于事件时间属性EventTime定义10分钟滚动窗口
WindowGroupedTable windowedTable = table.window(Tumble.over("10.minutes").on($("EventTime")).as("w"))
    .groupBy($("w"), $("GroupingColumn"));
// 窗口聚合后建议明确指定查询字段，避免select *引发的解析问题
table = windowedTable.select($("GroupingColumn"), $("w").start(), $("w").end(), $("w").rowtime());

额外说明 #

• 窗口分组后，原表结构和聚合后的表结构存在差异，直接使用select *容易引发字段解析异常，建议明确指定需要的字段，比如窗口的起始/结束时间、分组字段以及聚合计算结果。
• 如果要使用处理时间窗口，需单独定义处理时间属性（例如$("proctime").proctime()，前提是先声明处理时间字段），不能在事件时间字段上调用proctime()。

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