MyqueWooMiddo opened a new issue, #13560:
URL: https://github.com/apache/gravitino/issues/13560

   ### Version
   
   main branch
   
   ### Describe what's wrong
   
   I used Flink 1.18/1.20 to connect Gravitino's Metalake with official 
connector.
   There're to catalogs in Metalake, one is Paimon jdbc catalog , another is 
Gravitino's AUX IRC
   
   ### Error message and/or stacktrace
   
   could not find error message from flink sql shell ,and gravitino-server log
   
   ### How to reproduce
   
   I entered flink's sqli-client , then create a paimon PK table in paimon 
catalog.
   The table's four-level ident is 
metalake.paimon.paimon_metalake_db.test_for_pk_table,
   with properties as below :
   'metadata.iceberg.storage' = 'rest-catalog',
   'metadata.iceberg.rest.uri' = 'http://$gravitino-server:9001/iceberg', -- 
Gravitino's AUX IRC
   'metadata.iceberg.rest.warehouse' = 'irc',
   'metadata.iceberg.rest.clients' = '1'
   
   
   insert into test_for_pk_table first batch,flink can select all data in the 
first insert
   
   insert into test_for_pk_table second batch, flink can only select all data 
in the first insert too, could not find the second insert.
   
   
   snapshot-id : 1
         "summary": {
           "operation": "append",
           "added-data-files": "2",
           "total-equality-deletes": "0",
           "added-records": "2",
           "deleted-data-files": "0",
           "deleted-records": "0",
           "total-records": "2",
           "removed-files-size": "0",
           "changed-partition-count": "2",
           "total-position-deletes": "0",
           "added-files-size": "4175",
           "total-delete-files": "0",
           "total-files-size": "4175",
           "total-data-files": "2"
         }
   
   snapshot-id: 2
        "summary": {
           "operation": "append",
           "added-data-files": "0",
           "total-equality-deletes": "0",
           "added-records": "0",
           "deleted-data-files": "0",
           "deleted-records": "0",
           "total-records": "2",
           "removed-files-size": "0",
           "changed-partition-count": "0",
           "total-position-deletes": "0",
           "added-files-size": "0",
           "total-delete-files": "0",
           "total-files-size": "4175",
           "total-data-files": "2"
         }
   
   ### Additional context
   
   _No response_


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

Reply via email to