为了更快的定位您的问题,请提供以下信息,谢谢
【详述】问题详细描述
【背景】做过哪些操作?
【业务影响】
【StarRocks版本】3.1.2
【集群规模】例如:3fe(2 follower)+20be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:48C/64G/万兆
【联系方式】为了在解决问题过程中能及时联系到您获取一些日志信息,请补充下您的联系方式,例如:社区群4-王磊
【附件】
- fe.log/beINFO/相应截图
iceberg catalog查询报错
fe.warn.log内容:
建表语句:
CREATE TABLE spark_catalog.bss_ods.ord_customer_order (
CUST_ORDER_ID BIGINT NOT NULL,
VER_NUM INT NOT NULL,
ORDER_HANDLER_ID BIGINT,
OPER_TYPE STRING NOT NULL,
AUTH_TYPE STRING,
CUST_ID BIGINT NOT NULL,
CUST_ORDER_NBR STRING,
CUST_ORDER_TYPE STRING,
PRE_HANDLE_FLAG STRING,
PRIORITY INT,
ACCEPT_DATE TIMESTAMP,
ACCEPT_LAN_ID BIGINT NOT NULL,
ACCEPT_REGION_ID BIGINT NOT NULL,
ORDER_SOURCE STRING,
SOURCE_ORDER_ID DECIMAL(30,0),
PLAN_ACT_DATE TIMESTAMP,
REMARK STRING,
STATUS_CD STRING NOT NULL,
STATUS_DATE TIMESTAMP,
CREATE_POST BIGINT NOT NULL,
CREATE_ORG_ID BIGINT NOT NULL,
CREATE_STAFF BIGINT NOT NULL,
CREATE_DATE TIMESTAMP,
UPDATE_STAFF BIGINT,
UPDATE_DATE TIMESTAMP,
UPDATE_POST BIGINT,
UPDATE_ORG BIGINT,
EXT_CUST_ORDER_ID STRING,
SYS_SOURCE BIGINT NOT NULL,
ORD_PAY_METHOD BIGINT,
EXT_ORDER_NBR STRING,
ADDRESS_LAN_ID BIGINT,
ADDRESS_REGION_ID BIGINT,
etl_time TIMESTAMP)
USING iceberg
COMMENT ‘客户在中国电信发起一次业务交互事件’
LOCATION ‘hdfs://jf-iceberg/iceberg/jf_hive_catalog/warehouse/BSS_ODS.db/ord_customer_order’
TBLPROPERTIES (
‘current-snapshot-id’ = ‘3830029648937547134’,
‘format’ = ‘iceberg/parquet’,
‘format-version’ = ‘2’,
‘identifier-fields’ = ‘[CUST_ORDER_ID]’,
‘write.delete.mode’ = ‘merge-on-read’,
‘write.distribution-mode’ = ‘hash’,
‘write.merge.mode’ = ‘merge-on-read’,
‘write.metadata.delete-after-commit.enabled’ = ‘true’,
‘write.metadata.metrics.default’ = ‘full’,
‘write.metadata.previous-versions-max’ = ‘50’,
‘write.spark.accept-any-schema’ = ‘true’,
‘write.update.mode’ = ‘merge-on-read’,
‘write.upsert.enabled’ = ‘true’)