Spark SQL计算年龄时CASE语句报错问题排查

问题根源 #

你遇到的mismatched input 'CAST'错误，本质是CASE表达式分支返回类型不统一导致的解析异常：你的THEN分支返回整数1，而ELSE分支返回decimal(7,2)类型，Spark SQL要求CASE所有分支的返回类型必须一致，这种类型冲突会触发语法解析错误。

修复后的两种写法 #

写法1：统一CASE分支的返回类型

直接将THEN的1转换为decimal(7,2)类型，确保和ELSE分支类型一致：

CASE 
    WHEN months_between(CURRENT_DATE, birth_date)/12 < 1 THEN CAST(1 AS decimal(7,2))
    ELSE CAST(months_between(CURRENT_DATE, birth_date)/12 AS decimal(7,2)) 
END AS age

写法2：用GREATEST函数简化逻辑（更推荐）

因为你的需求是取「计算年龄」和「1」的最大值，直接用GREATEST函数可以避免重复计算，再统一转换为目标类型：

CAST(GREATEST(months_between(CURRENT_DATE, birth_date)/12, 1) AS decimal(7,2)) AS age

额外优化：避免重复计算 #

如果需要多次使用这个年龄计算值，可以用CTE（公共表表达式）提前计算原始年龄，提升代码可读性和执行效率：

WITH raw_data AS (
    SELECT 
        birth_date,
        months_between(CURRENT_DATE, birth_date)/12 AS raw_age
        -- 其他需要查询的字段
    FROM your_table_name
)
SELECT 
    birth_date,
    CAST(GREATEST(raw_age, 1) AS decimal(7,2)) AS age
    -- 其他字段
FROM raw_data

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