I have configured the external catalog in starrocks to access iceberg data.
Using below code i have created :
from sqlalchemy import create_engine
# SQLAlchemy connection string
engine = create_engine("mysql+pymysql://root:@xx.xx.xx.xx:9030", echo=False)
create_catalog_sql = """
CREATE EXTERNAL CATALOG iceberg_catalog_demo102
PROPERTIES (
"type" = "iceberg",
"iceberg.catalog.type" = "hive",
"iceberg.catalog.hive.metastore.uris" = "thrift://xxxxxxxxxxxxxxxxx.local:9083",
"azure.adls2.storage_account" = "xxxxxxxxxxxxxxxxxxxx",
"azure.adls2.shared_key" = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
);
"""
with engine.connect() as conn:
conn.execute(create_catalog_sql)
Using external catalog which i created i am able to query all data base and its respective tables .
But when i try to query the data from any one the table i am getting below error:
i validate table name and query are correct. But still its showing error :
Error is:
Executing query: SELECT * FROM iceberg_catalog_demo102.vedanta_dn_test_latest.am_category LIMIT 10
Failed to query table 'am_category': 1064 (HY000): Unknown table 'vedanta_dn_test_latest.am_category'