MoveLiu opened a new issue, #8417:
URL: https://github.com/apache/iceberg/issues/8417
### Query engine
I have a question.
set iceberg.catalog.hadoop.type = hadoop;
set iceberg.catalog.hadoop.warehouse = hdfs://192.168.221.140:8020/tmp/sebu;
CREATE database if not exists iceberg_hadoop_sebu;
drop table if exists iceberg_hadoop_sebu.ods_sn_gate_data_original;
create external table iceberg_hadoop_sebu.ods_sn_gate_data_original
(
sn STRING COMMENT '设备编号',
gate STRING COMMENT '网关',
source STRING COMMENT '数据源',
tp BIGINT COMMENT '设备上报时间戳',
ctp BIGINT COMMENT '收集时间戳',
atp BIGINT COMMENT '抵达时间戳',
content STRING COMMENT '详细内容'
)
PARTITIONED BY
(
ds string,
hr string
)
stored by 'org.apache.iceberg.mr.hive.HiveIcebergStorageHandler'
location
'hdfs://192.168.221.140:8020/tmp/sebu/iceberg_hadoop_sebu/ods_sn_gate_data_original'
tblproperties ('iceberg.catalog' = 'hadoop',
'write.metadata.previous-versions-max' = '200',
'write.metadata.delete-after-commit.enabled' = 'true',
'write.distribution-mode' = 'none');
This is my iceberg table ,but i can not read it on flink-sql;
### Question
I have a question.
set iceberg.catalog.hadoop.type = hadoop;
set iceberg.catalog.hadoop.warehouse = hdfs://192.168.221.140:8020/tmp/sebu;
CREATE database if not exists iceberg_hadoop_sebu;
drop table if exists iceberg_hadoop_sebu.ods_sn_gate_data_original;
create external table iceberg_hadoop_sebu.ods_sn_gate_data_original
(
sn STRING COMMENT '设备编号',
gate STRING COMMENT '网关',
source STRING COMMENT '数据源',
tp BIGINT COMMENT '设备上报时间戳',
ctp BIGINT COMMENT '收集时间戳',
atp BIGINT COMMENT '抵达时间戳',
content STRING COMMENT '详细内容'
)
PARTITIONED BY
(
ds string,
hr string
)
stored by 'org.apache.iceberg.mr.hive.HiveIcebergStorageHandler'
location
'hdfs://192.168.221.140:8020/tmp/sebu/iceberg_hadoop_sebu/ods_sn_gate_data_original'
tblproperties ('iceberg.catalog' = 'hadoop',
'write.metadata.previous-versions-max' = '200',
'write.metadata.delete-after-commit.enabled' = 'true',
'write.distribution-mode' = 'none');
This is my iceberg table ,but i can not read it on flink-sql;
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
