[GitHub] [iceberg] yinshan612 opened a new issue, #6262: Does iceberg not support stream reading and updating tables

[GitBox]

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

   ### Query engine
   
   Flink
   
   ### Question
   
   Read the test table through the iceberg stream, and then update the test. 
The stream read task will report an error and terminate. Is this a bug or a 
function not implemented at present
   
   一.sqlclient
   
    CREATE TABLE test2(
     id BIGINT COMMENT 'unique id',
      data STRING,
     primary key(id) not ENFORCED
    ) WITH (
       'connector'='iceberg',
       'catalog-name'='hadoop_catalog',
       'catalog-type'='hadoop',  
       'warehouse'='hdfs://nn1:8020/warehouse/iceberg1',
       'format-version'='2'
     );
   
   insert into test2 values (1,'202-11-20');
   insert into test2 values (1,'2022-11-11');
   
   二.other sqlclient
   
   select * from test2 OPTIONS('streaming'='true', 'monitor-interval'='10s');
   
   
   


-- 
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