我正在使用 Confluence Iceberg 接收器将数据从 Kafka 写入 Minio。该目录是 REST 目录。 我可以看到目录中的表格:
trino> show tables from iceberg.callcenter;
Table
-------------
calldetails
calls
customers
我看到表格的列:
trino> describe iceberg.callcenter.customers;
Column | Type | Extra | Comment
------------+---------+-------+---------
customerid | bigint | |
name | varchar | |
address | varchar | |
membership | varchar | |
class | varchar | |
(5 rows)
但是当我想查询表时,我收到以下消息:
trino> select customerid, name, address from iceberg.callcenter.customers;
Query 20240926_181431_00023_dx4ne failed: Error processing metadata for table callcenter.customers
我不明白这里的问题
我遇到了同样的问题,并修改了 trino 的icerberg.properties 我能够修复它
connector.name=iceberg
iceberg.catalog.type=rest
iceberg.rest-catalog.uri=http://iceberg-rest:8181
iceberg.rest-catalog.warehouse=s3://warehouse/
iceberg.file-format=PARQUET
fs.native-s3.enabled=true
s3.endpoint=http://minio:9000
s3.region=us-east-1
s3.path-style-access=true
s3.aws-access-key=****
s3.aws-secret-key=****
iceberg.compression-codec=ZSTD