krvikash commented on issue #6180:
URL: https://github.com/apache/iceberg/issues/6180#issuecomment-1312779669
Hi @get1boat,
You are missing the primary key while creating the table.
> Enabling UPSERT mode using upsert-enabled in the [write options](#Write
options) provides more flexibility than a table level config. Note that you
still need to use v2 table format and specify the primary key when creating the
table.
https://iceberg.apache.org/docs/latest/flink/#upsert
Please try adding a `PRIMARY KEY` while creating the table like below.
`CREATE TABLE hive_catalog.ods_ice.tmp_lkj_kafka2iceberg( id varchar NOT
NULL, create_time timestamp(6), user_id bigint, PRIMARY KEY(id) NOT ENFORCED )
WITH ( format = 'PARQUET', format_version = 2, location =
'hdfs://eva:8020/user/hive/warehouse/ods_ice.db/tmp_lkj_kafka2iceberg' ) ;`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
