如何使用Flink创建基于STRUCT/ROW类型内部字段分区的Iceberg表？

你遇到的核心问题是：Flink SQL不支持直接用嵌套ROW类型里的字段作为分区键，语法解析器无法识别PARTITIONED BY子句中的点号路径访问，所以无论加不加单引号都会触发解析错误。

给你两个可行的解决办法：

方法一：拆分嵌套字段到顶层 #

把需要作为分区键的嵌套字段单独提取为顶层列，再用顶层列做分区，示例SQL如下：

CREATE TABLE test (
    id STRING,
    name STRING,
    nested ROW(id STRING, name STRING) -- 可选保留原嵌套结构
) PARTITIONED BY (id);

如果不需要保留原嵌套字段，也可以直接定义成顶层字段：

CREATE TABLE test (
    id STRING,
    name STRING
) PARTITIONED BY (id);

方法二：先转换数据再写入分区表 #

如果必须保留原嵌套结构，可以在数据写入前做转换：

• 用Flink DataStream API读取数据后，提取nested.id作为单独字段，再写入分区表；
• 或者先创建一个不带分区的基础表，再创建视图提取嵌套字段，通过视图将数据写入分区表。

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