![]() config(".url", "MY JDBC H2 URI that is used wuth iceberg JDBCATALOG") config("", ".extensions.IcebergSparkSessionExtensions") ![]() I have set the configuration properties for spark session to use. ![]() When I create a spark session in the same class, it is unable to use the JdbcCatalog already created using iceberg API, it either sets up its own catalog or errors out initializing JdbcCatalog saying ICEBERG_TABLES exists ( which is expected as iceberg jdbc catalog already would have the meta tables ) It is able to create iceberg tables with proper schema and partition spec.
0 Comments
Leave a Reply. |
Details
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |