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

   ### 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
   
   ERROR [Gravitino-webserver-99] 
[org.apache.gravitino.catalog.OperationDispatcher.operateOnEntity(OperationDispatcher.java:211)]
 - Entity for metalake.paimon.paimon_metalake_db.test_for_pk_table4 doesn't 
exist in Gravitino, this is unexpected if this is created by Gravitino. With 
this situation the returned object will not contain the metadata from Gravitino
   
   WARN [Gravitino-webserver-99] 
[org.apache.gravitino.server.web.rest.ExceptionHandlers$TableExceptionHandler.handle(ExceptionHandlers.java:267)]
 - Failed to operate table(s) [test_for_pk_table4] operation [LOAD] under 
schema [paimon_metalake_db], reason [Table managed by multiple catalogs. This 
may cause unexpected issues such as privilege conflicts. To resolve: Remove all 
catalogs managing this table, then recreate one catalog to ensure 
single-catalog management.]
   java.lang.UnsupportedOperationException: Table managed by multiple catalogs. 
This may cause unexpected issues such as privilege conflicts. To resolve: 
Remove all catalogs managing this table, then recreate one catalog to ensure 
single-catalog management.
   at 
org.apache.gravitino.catalog.TableOperationDispatcher.loadTable(TableOperationDispatcher.java:160)
   
   ### How to reproduce
   
   I entered flink's sqli-client , then create a paimon table in paimon catalog.
   The table's four-level ident is 
metalake.paimon.paimon_metalake_db.test_for_pk_table4,
   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'
   
   The table could be created by flink ,but flink could not select / insert / 
drop it , which willl throw excetion
   
   ### Additional context
   
   gravitino 1.3.0


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