Spark SQL执行Oracle兼容SQL报错，请求排查语法差异及修复方案

这是Spark SQL与Oracle SQL的语法差异导致的，结合你使用的Spark 0.2.1（极其老旧的版本，SQL语法支持有限），主要问题和修复方式如下：

核心问题 #

1. 特殊字符列名的处理：Spark SQL中，列名包含$这类特殊符号时，必须用反引号（`）包裹才能正确识别，而Oracle对这类列名的兼容性更好，无需额外处理。
2. CASE语句的冗余逻辑：原SQL中limit_max IS NULL被重复判断，老版本Spark的SQL解析器可能对这种冗余嵌套的逻辑处理存在兼容性问题。

修复后的SQL #

SELECT
a.*,
( a.clc_1 + a.clc_2 + a.clc_3 ) / 3 AS arpu,
CASE 
    WHEN limit_max IS NULL OR limit_max < 1 THEN 
        CASE 
            WHEN `break_$` < 1 OR `break_$` IS NULL THEN 0.01
            ELSE `break_$` 
        END
    ELSE limit_max
END AS old_limit
FROM def.FEAUTRES_TEST_1  a

额外说明 #

Spark 0.2.1的SQL语法规范远不如新版本完善，也和Oracle SQL存在诸多差异。如果条件允许，建议升级到更高版本的Spark（如2.x或3.x），能大幅减少这类兼容性问题，同时获得更好的性能和功能支持。

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