Re: Support Flink SQL Upsert a Spark table

2024-01-10 Thread xianjin
You can create an Iceberg table with required field, for example: create table test_table (id bigint not null, data string) using iceberg However you can not change the optional field to required after creation. See this issue for more details: https://github.com/apache/iceberg/issues/3617 Manu

Re: Support Flink SQL Upsert a Spark table

2024-01-10 Thread Manu Zhang
It looks like there's no way to explicitly add a required column in DDL. Any suggestions? Much appreciated Manu On Tue, Jan 9, 2024 at 3:37 PM Manu Zhang wrote: > Thanks Peter and Ryan for the info. > > As identifier fields need to be "required", how can I alter an optional > column to be requi