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: [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]
