jasonrig-ppcd opened a new issue, #13235: URL: https://github.com/apache/iceberg/issues/13235
### Apache Iceberg version 1.9.1 (latest release) ### Query engine Flink ### Please describe the bug 🐞 The Flink Getting Started document states: > catalog-type: hive, hadoop, rest, glue, jdbc or nessie for built-in catalogs, or left unset for custom catalog implementations using catalog-impl. (Optional) Source: https://iceberg.apache.org/docs/1.9.1/flink/#catalog-configuration But setting this value to, for example, `jdbc`, results in: ``` Exception in thread "main" java.lang.UnsupportedOperationException: Unknown catalog-type: jdbc (Must be 'hive', 'hadoop' or 'rest') at org.apache.iceberg.flink.FlinkCatalogFactory.createCatalogLoader(FlinkCatalogFactory.java:119) at org.apache.iceberg.flink.FlinkCatalogFactory.createCatalog(FlinkCatalogFactory.java:144) at org.apache.iceberg.flink.FlinkCatalogFactory.createCatalog(FlinkCatalogFactory.java:139) at org.apache.flink.table.factories.FactoryUtil.createCatalog(FactoryUtil.java:492) at org.apache.flink.table.catalog.CatalogManager.initCatalog(CatalogManager.java:376) at org.apache.flink.table.catalog.CatalogManager.createCatalog(CatalogManager.java:330) at org.apache.flink.table.operations.ddl.CreateCatalogOperation.execute(CreateCatalogOperation.java:88) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1102) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:735) ``` It appears that the necessary cases in the `switch` statement of `FlinkCatelogFactory` and corresponding `CatalogLoader`s are missing ([Flink v1.20](https://github.com/apache/iceberg/blob/931865ecaf40a827f9081dddb675bf1c95c05461/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java#L102-L121) & [Flink v2.0](https://github.com/apache/iceberg/blob/931865ecaf40a827f9081dddb675bf1c95c05461/flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/FlinkCatalogFactory.java#L102-L122)). I believe either the docs should be updated to mention this, or the support should be added. (Or indeed let me know if I've missed any important point.) ### Willingness to contribute - [ ] I can contribute a fix for this bug independently - [x] I would be willing to contribute a fix for this bug with guidance from the Iceberg community - [ ] I cannot contribute a fix for this bug at this time -- 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
