Doris2.1.7 插入 hive 表报错

Viewed 96

执行 sql 语句从 doris 向 hive 插入数据报错:
ERROR 1105 (HY000): errCode = 2, detailMessage = Not support insert target table.

执行语句 :insert into hive.test.cwl_usl_sales select ticket_id,sales_issue,sale_date,money,raw_hash,raw_data cwl_id,valid_issue,province FROM ticket.cwl_usl_sales;

catalog 创建语句
CREATE CATALOG hive PROPERTIES (
"type"="hms",
"hive.metastore.uris" = "thrift://name1:9083",
"hadoop.username" = "hdfs",
"fs.defaultFS" = "hdfs://name1:8020"
);

hive 建表语句
CREATE TABLE test.cwl_usl_sales(
ticket_id string COMMENT '?????????',
sales_issue string COMMENT '????',
sale_date string COMMENT '????',
money decimal(20,2) COMMENT '????',
raw_hash string COMMENT '?????????hash',
raw_data string COMMENT '????????')
COMMENT '??????'
PARTITIONED BY (
cwl_id string COMMENT '??id',
valid_issue string COMMENT '????',
province string COMMENT '??')
ROW FORMAT SERDE
'org.apache.hadoop.hive.ql.io.parquet.serde.ParquetHiveSerDe'
STORED AS INPUTFORMAT
'org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat'
OUTPUTFORMAT
'org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat'
LOCATION
'hdfs://name-node1:8020/user/hive/warehouse/test.db/cwl_usl_sales'
TBLPROPERTIES (
'parquet.compression'='SNAPPY',
'transient_lastDdlTime'='1733904350')

doris 建表语句
CREATE TABLE ticket.cwl_usl_sales (
part_key varchar(100) NOT NULL ,
ticket_id varchar(64) NOT NULL ,
province varchar(4) NOT NULL,
sales_issue varchar(20) NOT NULL,
cwl_id varchar(20) NOT NULL,
valid_issue varchar(20) NOT NULL,
sale_date date NULL,
money decimal(9,0) NULL,
raw_hash varchar(64) NULL,
raw_data varchar(65533) NULL,
) ENGINE=OLAP
UNIQUE KEY(part_key, ticket_id)
COMMENT '电脑票销售票表'
AUTO PARTITION BY LIST (part_key)
()
DISTRIBUTED BY HASH(ticket_id) BUCKETS 12
PROPERTIES (
"replication_allocation" = "tag.location.default: 3",
"min_load_replica_num" = "-1",
"is_being_synced" = "false",
"storage_medium" = "hdd",
"storage_format" = "V2",
"inverted_index_storage_format" = "V1",
"enable_unique_key_merge_on_write" = "true",
"light_schema_change" = "true",
"disable_auto_compaction" = "false",
"enable_single_replica_compaction" = "false",
"group_commit_interval_ms" = "10000",
"group_commit_data_bytes" = "134217728",
"enable_mow_light_delete" = "false"
);

1 Answers

你这个关一下这个开关,set enable_fallback_to_original_planner=false然后在当前session执行看下