[GitHub] [iceberg] get1boat opened a new issue, #6180: can't upsert v2 table by add hint /*+ OPTIONS('upsert-enabled'='true') */

[GitBox]

get1boat opened a new issue, #6180:
URL: https://github.com/apache/iceberg/issues/6180

   ### Apache Iceberg version
   
   1.0.0 (latest release)
   
   ### Query engine
   
   Flink
   
   ### Please describe the bug 🐞
   
   table DDL:
   `
   CREATE TABLE hive_catalog.ods_ice.tmp_lkj_kafka2iceberg (
      id varchar NOT NULL,
      create_time timestamp(6),
      user_id bigint
   )
   WITH (
      format = 'PARQUET',
      format_version = 2,
      location = 
'hdfs://eva:8020/user/hive/warehouse/ods_ice.db/tmp_lkj_kafka2iceberg'
   )
   ;
   `
   with the hint,insert 2 rows which having the same key by trino:
   `
   insert into hive_catalog.ods_ice.tmp_lkj_kafka2iceberg /*+ 
OPTIONS('upsert-enabled'='true') */
   select '1'as id ,localtimestamp  as create_time,111 as user_id
   ;
   insert into hive_catalog.ods_ice.tmp_lkj_kafka2iceberg /*+ 
OPTIONS('upsert-enabled'='true') */
   select '1'as id ,localtimestamp  as create_time,222 as user_id
   ;
   `
   Then,we select the table and we found it has two rows with the same 
key.Upsert hint did not work:
   
![image](https://user-images.githubusercontent.com/68981063/201518039-a32f37b4-9098-4fd3-8671-e60314705aef.png)
   
   


-- 
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: issues-unsubscr...@iceberg.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org