Uh oh!
There was an error while loading.Please reload this page.
- Notifications
You must be signed in to change notification settings - Fork57
Open
Description
Glad to see the new version can write/read Iceberg.
I configured one on GCP using Apache Gravitino as Iceberg Rest Catalog and GCS over S3 XML API. It works with SparkSQL. The sling env.yaml is like this
GCP_ICEBERG:type:icebergcatalog_type:restcatalog_name:iceberg_catalogschema:iceberg_rest_demorest_uri:http://gravitino.demo.timeplus.com:9001/iceberg/rest_warehouse:gs3://tpice/gravitino/gcs_as_s3rest_oauth_client_id:..rest_oauth_client_secret:..s3_region:autos3_endpoint:https://storage.googleapis.com
I can discover the table via IRC
sling conns discover GCP_ICEBERG+---+----------+-------------------+------+-------+| # | DATABASE | SCHEMA | NAME | TYPE |+---+----------+-------------------+------+-------+| 1 | iceberg | iceberg_rest_demo | test | table |+---+----------+-------------------+------+-------+But I cannot query it via SQL
sling run --src-conn GCP_ICEBERG --src-stream "SELECT * FROM iceberg_catalog.iceberg_rest_demo.test" --stdout7:35PM INF Sling CLI | https://slingdata.io7:35PM INF connecting to source database (iceberg)7:35PM INF reading from source database7:35PM INF execution failedfatal:~ Failed to load table .NoSuchNamespaceException: Namespace does not exist: tablesI tried differentFROM, using the catalog_name or schema or the hardcoded iceberg, always got this "Namespace does not exist: tables"
Any clue? Thanks
Metadata
Metadata
Assignees
Labels
No labels