使用PySpark 3.5.1向Iceberg加载数据时遇SQL语法错误求助

你的报错源于Spark SQL解析Iceberg ALTER语句时的语法错误，修正后的正确语句如下：

%%sparksql

ALTER TABLE
    scheme.table
SET IDENTIFIER FIELDS (a, b, c);

ALTER TABLE
    scheme.table
SET WRITE DISTRIBUTED BY PARTITION LOCALLY ORDERED BY (d, e ASC NULLS LAST);

核心修正点： #

• SET IDENTIFIER FIELDS 后的字段列表必须用**括号()**包裹，你之前的写法缺少括号，导致解析器无法识别字段的结束位置，误将分号判定为非法输入。
• WRITE DISTRIBUTED BY ... 语句需要在开头添加SET关键字，同时排序字段列表也需用括号包裹，这是Iceberg的标准语法要求。

另外，建议确认你的Iceberg版本是否与Spark 3.5.1兼容（Iceberg 1.4.0及以上版本对Spark 3.5的支持更完善），旧版本可能存在语法兼容性问题。

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