Flink SQL 1.11查询嵌套ROW字段报scala.MatchError错误如何解决

问题根因 #

该报错属于Flink 1.11版本内置Calcite解析器的已知边界问题，由以下几个常见触发点导致：

• 表结构ROW字段定义语法错误：你提供的fd_output字段定义中，restime和outcome两个子字段之间缺失逗号分隔符，会导致解析器无法正确识别ROW结构，触发非预期的隐式类型转换逻辑。
• 时间函数隐式转换bug：Flink 1.11版本中YEAR()、MONTH()函数直接作用于TIMESTAMP(3)精度的时间字段时，会触发Calcite解析器生成多余的CAST操作，命中解析匹配逻辑的bug就会抛出scala.MatchError: CAST异常。
• 嵌套字段解析歧义：未加括号直接访问ROW子字段时，部分场景下解析器会误判语法优先级，额外生成类型转换逻辑。

修复步骤 #

1. 先修正表结构的ROW字段定义，补全子字段间的逗号，正确的字段定义为：

`fd_output` ROW<`restime` BIGINT, `outcome` VARCHAR(64)>

修正后重新创建org_table表。

2. 调整查询语句，显式处理时间字段类型转换，同时给嵌套字段访问加括号消除解析歧义，修改后的查询语句如下：

SELECT 
  transaction_amt, 
  transaction_adj_amt, 
  event_time, 
  (fd_output).restime AS response_time, 
  (fd_output).outcome AS outcome,  
  YEAR(CAST(event_time AS TIMESTAMP)), 
  MONTH(CAST(event_time AS TIMESTAMP)) 
FROM org_table

3. 如果上述操作后仍报错，可以在作业启动参数中添加配置关闭非必要的隐式类型转换：

table.optimizer.implicit-type-cast.enabled = false

内容的提问来源于stack exchange，提问作者Ahmed Saif Zamzam