openinx commented on issue #3114:
URL: https://github.com/apache/iceberg/issues/3114#issuecomment-919073754
I've checked the behavior by using iceberg master branch (git commit-id:
838cc652273c1444155bec2e1d6029cfbdbf3ea3) and flink 1.12, all work as
expected:
```sql
CREATE TABLE iceberg_table_v2 (
id BIGINT,
data STRING,
PRIMARY KEY (id) NOT ENFORCED
) WITH (
'connector'='iceberg',
'format-version' = '2',
'catalog-name'='hadoop_prod',
'catalog-type'='hadoop',
'write.upsert.enable'='true',
'warehouse'='file:///Users/openinx/test/iceberg-warehouse'
);
select * from iceberg_table_v2;
+----+------+
| id | data |
+----+------+
0 row in set
INSERT INTO iceberg_table_v2 VALUES (14, 'test14'), (14, 'test14_update');
[INFO] Submitting SQL update statement to the cluster...
[INFO] Table update statement has been successfully submitted to the cluster:
Job ID: 083d3008e12bc533aacec0c2bdae9d0a
select * from iceberg_table_v2;
+----+---------------+
| id | data |
+----+---------------+
| 14 | test14_update |
+----+---------------+
1 row in set
```
--
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]
