hive外部表数据同步至StarRcoks内部表异常

💬 StarRocks 用户问答 功能使用相关
#1

问题:

image
image1113×165 3.71 KB

FE异常栈信息：
image
image1380×493 361 KB

dumpfile内容:
dumpFile (10.3 KB)
其中内部表 建表语句 a003_a.ds_normal_chks_info_copy
CREATE TABLE ds_normal_chks_info_copy (
shop_id varchar(65533) NULL COMMENT “”,
olet_id varchar(65533) NULL COMMENT “”,
bday_date varchar(65533) NULL COMMENT “”,
chks_non_revenue varchar(13) NULL COMMENT “”,
shop_name varchar(65533) NULL COMMENT “”,
chks_id varchar(65533) NULL COMMENT “”,
pdtp_seq int(11) NULL COMMENT “”,
serving_period varchar(65533) NULL COMMENT “”,
olet_name varchar(65533) NULL COMMENT “”,
enterprisecurrency666_total_revenue decimal128(37, 8) NULL COMMENT “”,
propertycurrency666_total_revenue decimal128(22, 4) NULL COMMENT “”,
enterprisecurrency666_net_sales decimal128(38, 8) NULL COMMENT “”,
propertycurrency666_net_sales decimal128(38, 4) NULL COMMENT “”,
enterprisecurrency666_gross_sales decimal128(38, 8) NULL COMMENT “”,
propertycurrency666_gross_sales decimal128(38, 4) NULL COMMENT “”,
enterprisecurrency666_chks_discount decimal128(37, 8) NULL COMMENT “”,
propertycurrency666_chks_discount decimal128(22, 4) NULL COMMENT “”,
enterprisecurrency666_service_charges decimal128(38, 8) NULL COMMENT “”,
propertycurrency666_service_charges decimal128(38, 4) NULL COMMENT “”,
enterprisecurrency666_chks_tips_total decimal128(35, 8) NULL COMMENT “”,
propertycurrency666_chks_tips_total decimal128(20, 4) NULL COMMENT “”,
enterprisecurrency666_taxes decimal128(38, 8) NULL COMMENT “”,
propertycurrency666_taxes decimal128(38, 4) NULL COMMENT “”,
enterprisecurrency666_rounding decimal128(35, 8) NULL COMMENT “”,
propertycurrency666_rounding decimal128(20, 4) NULL COMMENT “”,
enterprisecurrency666_chks_payment_total decimal128(37, 8) NULL COMMENT “”,
propertycurrency666_chks_payment_total decimal128(22, 4) NULL COMMENT “”,
reopen_check_count int(11) NULL COMMENT “”,
enterprisecurrency666_reopen_check_total decimal128(35, 8) NULL COMMENT “”,
propertycurrency666_reopen_check_total decimal128(20, 4) NULL COMMENT “”,
reopen_check_emplyee varchar(65533) NULL COMMENT “”,
reopen_chks_time varchar(65533) NULL COMMENT “”,
reopen_chks_check_prefix_num varchar(65533) NULL COMMENT “”,
reopen_chks_id varchar(65533) NULL COMMENT “”,
chks_check_prefix_num varchar(65533) NULL COMMENT “”,
check_count int(11) NULL COMMENT “”,
check_emplyee varchar(65533) NULL COMMENT “”,
bday_end_loctime varchar(65533) NULL COMMENT “”,
bday_status varchar(65533) NULL COMMENT “”,
bday_start_loctime varchar(65533) NULL COMMENT “”,
chks_open_loctime varchar(65533) NULL COMMENT “”,
tenant_id varchar(65533) NULL COMMENT “”,
ab_partition varchar(65533) NULL COMMENT “”
) ENGINE=OLAP
DUPLICATE KEY(shop_id, olet_id)
COMMENT “OLAP”
DISTRIBUTED BY HASH(tenant_id, bday_date) BUCKETS 4
PROPERTIES (
“replication_num” = “3”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”
);

SR-hive外部表建表语句：

CREATE EXTERNAL TABLE a003_ds_normal_chks_info_copy (
shop_id varchar(65533) NULL COMMENT “”,
olet_id varchar(65533) NULL COMMENT “”,
bday_date varchar(65533) NULL COMMENT “”,
chks_non_revenue varchar(13) NULL COMMENT “”,
shop_name varchar(65533) NULL COMMENT “”,
chks_id varchar(65533) NULL COMMENT “”,
pdtp_seq int(11) NULL COMMENT “”,
serving_period varchar(65533) NULL COMMENT “”,
olet_name varchar(65533) NULL COMMENT “”,
enterprisecurrency666_total_revenue decimal128(37, 8) NULL COMMENT “”,
propertycurrency666_total_revenue decimal128(22, 4) NULL COMMENT “”,
enterprisecurrency666_net_sales decimal128(38, 8) NULL COMMENT “”,
propertycurrency666_net_sales decimal128(38, 4) NULL COMMENT “”,
enterprisecurrency666_gross_sales decimal128(38, 8) NULL COMMENT “”,
propertycurrency666_gross_sales decimal128(38, 4) NULL COMMENT “”,
enterprisecurrency666_chks_discount decimal128(37, 8) NULL COMMENT “”,
propertycurrency666_chks_discount decimal128(22, 4) NULL COMMENT “”,
enterprisecurrency666_service_charges decimal128(38, 8) NULL COMMENT “”,
propertycurrency666_service_charges decimal128(38, 4) NULL COMMENT “”,
enterprisecurrency666_chks_tips_total decimal128(35, 8) NULL COMMENT “”,
propertycurrency666_chks_tips_total decimal128(20, 4) NULL COMMENT “”,
enterprisecurrency666_taxes decimal128(38, 8) NULL COMMENT “”,
propertycurrency666_taxes decimal128(38, 4) NULL COMMENT “”,
enterprisecurrency666_rounding decimal128(35, 8) NULL COMMENT “”,
propertycurrency666_rounding decimal128(20, 4) NULL COMMENT “”,
enterprisecurrency666_chks_payment_total decimal128(37, 8) NULL COMMENT “”,
propertycurrency666_chks_payment_total decimal128(22, 4) NULL COMMENT “”,
reopen_check_count int(11) NULL COMMENT “”,
enterprisecurrency666_reopen_check_total decimal128(35, 8) NULL COMMENT “”,
propertycurrency666_reopen_check_total decimal128(20, 4) NULL COMMENT “”,
reopen_check_emplyee varchar(65533) NULL COMMENT “”,
reopen_chks_time varchar(65533) NULL COMMENT “”,
reopen_chks_check_prefix_num varchar(65533) NULL COMMENT “”,
reopen_chks_id varchar(65533) NULL COMMENT “”,
chks_check_prefix_num varchar(65533) NULL COMMENT “”,
check_count int(11) NULL COMMENT “”,
check_emplyee varchar(65533) NULL COMMENT “”,
bday_end_loctime varchar(65533) NULL COMMENT “”,
bday_status varchar(65533) NULL COMMENT “”,
bday_start_loctime varchar(65533) NULL COMMENT “”,
chks_open_loctime varchar(65533) NULL COMMENT “”,
tenant_id varchar(65533) NULL COMMENT “”,
ab_partition varchar(65533) NULL COMMENT “”
) ENGINE=HIVE
COMMENT “PARTITION BY (tenant_id, ab_partition)”
PROPERTIES (
“database” = “a003_b”,
“table” = “ds_normal_chks_info_copy”,
“resource” = “hiveRes”,
“hive.metastore.uris” = “thrift://10.73.9.85:9083”
);
ps：外部表数据为空表

#2

其中SR版本2.1.1

京ICP备2022026421号-1