如何通过flink_cdc把mysql的两张纵向切分的表在iceberg中合并成一张表

CREATE TABLE source_part_1 ( columns... PRIMARY KEY (pk) NOT ENFORCED ) WITH ( connectinfo... );

CREATE TABLE source_part_2 ( columns... PRIMARY KEY (pk) NOT ENFORCED ) WITH ( connectinfo... );

CREATE TABLE iceberg ( part_1_columns... part_2_columns... PRIMARY KEY (pk) NOT ENFORCED ) WITH ( connectinfo... );

insert into iceberg (part_1_columns...) select part_1_columns from source_part_1; insert into iceberg (part_2_columns...) select part_2_columns from source_part_2; 这种方式为什么写不进去