okayhooni commented on issue #9954:
URL: https://github.com/apache/iceberg/issues/9954#issuecomment-1997471383
@dyzcs Thank you for additional kind explanation..!
If catalog can be shared between DataStream API and Table API as your code,
How can I use that catalog on SQL interface from `StreamTableEnvironment` ?
`registerCatalog` method of `TableEnvironment` has catalog parameter typed
as `org.apache.flink.table.catalog`..!
But the catalog loaded from `CatalogLoader.custom()` is typed as
`org.apache.iceberg.catalog.Catalog`..! so it cannot be the argument of
`registerCatalog` method of `TableEnvironment`..!
```
val glueCatalogLoader = CatalogLoader.custom(
"iceberg_catalog",
Map(
"type" -> "iceberg",
"warehouse" -> "s3://thank-you-dyzcx",
"catalog-impl" -> "org.apache.iceberg.aws.glue.GlueCatalog",
"io-impl" -> "org.apache.iceberg.aws.s3.S3FileIO"
).asJava,
new Configuration,
"org.apache.iceberg.aws.glue.GlueCatalog"
)
val glueCatalog = glueCatalogLoader.loadCatalog // it is typed as
`org.apache.iceberg.catalog.Catalog`
// tableEnv.registerCatalog() ~ NOT WORKING WITH
`org.apache.iceberg.catalog.Catalog`, it needs `org.apache.flink.table.catalog`
```
--
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
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
