今天用seatunnel写入数据报错 但是手写insert 没问题
下面是建表语句,自动根据时间分区,后来试了一下删除自动分区 不分区了,也还是报这个错误
CREATE TABLE ods.ods_cart_info_full
(
`id` VARCHAR(255) COMMENT '编号',
`k1` DATEV2 NOT NULL COMMENT '分区字段',
`user_id` STRING COMMENT '用户id',
`sku_id` STRING COMMENT 'sku_id',
`cart_price` DECIMAL(16, 2) COMMENT '放入购物车时价格',
`sku_num` BIGINT COMMENT '数量',
`img_url` STRING COMMENT '商品图片地址',
`sku_name` STRING COMMENT 'sku名称 (冗余)',
`is_checked` STRING COMMENT '是否被选中',
`create_time` STRING COMMENT '创建时间',
`operate_time` STRING COMMENT '修改时间',
`is_ordered` STRING COMMENT '是否已经下单',
`order_time` STRING COMMENT '下单时间',
`source_type` STRING COMMENT '来源类型',
`source_id` STRING COMMENT '来源编号'
)
ENGINE=OLAP
UNIQUE KEY(`id`,`k1`)
COMMENT '购物车全量表'
AUTO PARTITION BY RANGE(date_trunc(k1, 'month')) ()
DISTRIBUTED BY HASH(`id`)
PROPERTIES
(
"replication_allocation" = "tag.location.default: 1"
);
再写入数据的时候 报错显示没有分区
Reason: no partition for this tuple. tuple=
+--------------------+---------------+-----------------------------+-----------------------------+------------------------------------------+------------------------------+-----------------------------+----------------------------------------+------------------------------------------+-----------------------------+----------------------------+--------------------------+----------------------------+----------------------------+--------------------------+------------------------------+-----------------------------+---------------------------+----------------------------+
|id(Nullable(String))|k1(DateV2) |coupon_name(Nullable(String))|coupon_type(Nullable(String))|condition_amount(Nullable(Decimal(16, 2)))|condition_num(Nullable(Int64))|activity_id(Nullable(String))|benefit_amount(Nullable(Decimal(16, 2)))|benefit_discount(Nullable(Decimal(16, 2)))|create_time(Nullable(String))|range_type(Nullable(String))|limit_num(Nullable(Int64))|taken_count(Nullable(Int64))|start_time(Nullable(String))|end_time(Nullable(String))|operate_time(Nullable(String))|expire_time(Nullable(String))|__DORIS_DELETE_SIGN__(Int8)|__DORIS_VERSION_COL__(Int64)|
+--------------------+---------------+-----------------------------+-----------------------------+------------------------------------------+------------------------------+-----------------------------+----------------------------------------+------------------------------------------+-----------------------------+----------------------------+--------------------------+----------------------------+----------------------------+--------------------------+------------------------------+-----------------------------+---------------------------+----------------------------+
| 1| 2020-10-23| 口红品类券| 3201| 99.00| NULL| NULL| 30.00| NULL| 2020-10-23T12:37:05| 3301| 100| 0| 2020-06-10T01:01:01| NULL| 2024-11-21T10:01:50| NULL| 0| 0|
+--------------------+---------------+-----------------------------+-----------------------------+------------------------------------------+------------------------------+-----------------------------+----------------------------------------+------------------------------------------+-----------------------------+----------------------------+--------------------------+----------------------------+----------------------------+--------------------------+------------------------------+-----------------------------+---------------------------+----------------------------+
3 rows in block, only show first 1 rows.