[GitHub] [iceberg] skywalker2256 commented on issue #6816: FlinkSql streaming read iceberg v2 table

["skywalker2256 (via GitHub)" <gi...@apache.org>]

skywalker2256 commented on issue #6816:
URL: https://github.com/apache/iceberg/issues/6816#issuecomment-1427301731

   > Here is what I did.
   
   CREATE TABLE sample_9 (
       id BIGINT COMMENT 'unique id',
       data BIGINT ,
      PRIMARY KEY(id) NOT ENFORCED
   ) with ('format-version'='2',
   'write.upsert.enabled'='true')
   ;
   
   query sql :
   select * from hive_catalog.iceberg_db.sample_9 /*+options('streaming'='true','monitor-interval'='5s')*/ ;
   
   result:
   ![image](https://user-images.githubusercontent.com/41573491/218367084-10ea34ef-f1fa-46bd-bb1b-7ea31ddf32c3.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-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