[GitHub] [iceberg] openinx edited a comment on issue #3114: after set 'write.upsert.enable'='true' in flink sql, using flink sql read iceberg table will get exception: java.lang.IllegalArgumentException: Row arity: 3, but serializer arity: 2

[GitBox <gi...@apache.org>]

openinx edited a comment 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
   
   INSERT INTO iceberg_table_v2 VALUES (14, 'test14_3');
   [INFO] Submitting SQL update statement to the cluster...
   [INFO] Table update statement has been successfully submitted to the cluster:
   Job ID: 9528163e8d06db33c090c16d9a858b45
   
   select * from iceberg_table_v2; 
   +----+----------+
   | id |     data |
   +----+----------+
   | 14 | test14_3 |
   +----+----------+
   1 row in set
   
   INSERT INTO iceberg_table_v2 VALUES (14, 'test14_4');
   [INFO] Submitting SQL update statement to the cluster...
   [INFO] Table update statement has been successfully submitted to the cluster:
   Job ID: 9543c0c29bc730ece8420066119f9abf
   
   select * from iceberg_table_v2;
   +----+----------+
   | id |     data |
   +----+----------+
   | 14 | test14_4 |
   +----+----------+
   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: issues-unsubscribe@iceberg.apache.org

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



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