DateV2类型类型写入不进去数据,改成varchar就可以了,是怎么回事?

提问者:帅平 问题分类:数据库
Flink-doris-connector-1.03中,使用DateV2类型不能写入数据,例如下面的sql:
CREATE TABLE IF NOT EXISTS demo.cdp_metric_test
(
        team_id bigint comment '店铺id',
    user_id varchar(64) comment '用户id',
    metric_code varchar(64) comment '特征code',
    metric_value varchar(256) comment '特征value',
    version varchar(64) comment '版本号',
    par datev2 comment '分区,格式yyyyMMdd'
)
DUPLICATE KEY(team_id,user_id)
PARTITION BY RANGE(par)()
DISTRIBUTED BY HASH(team_id)
PROPERTIES
(
    "dynamic_partition.enable" = "true",
    "dynamic_partition.time_unit" = "DAY",
    "dynamic_partition.end" = "3",
    "dynamic_partition.prefix" = "p",
    "dynamic_partition.buckets" = "8",
        "replication_num" = "1"
);

doris 2.0 版本建动态分区表,分区字段 par 的是 DateV2 类型,然后 Flink 1.13 版本,用 Flink-doris-connector-1.0.3 写入 par 是 Date 类型写入,但是报错。
1 个回答
咪有了
咪有了
升级connector 1.1.0以上,或者在flinksql里面用string接收
发布于:1年前 (2023-05-23) IP属地:四川省
帅平
帅平提问者
flink sql 用string接收 分区字段,写入 doris 的datev2 会自动转换的对吧
发布于:1年前 (2023-05-23) IP属地:四川省
岛是海碎了的心
岛是海碎了的心
flink sql 用string接收 分区字段,写入 doris 的datev2 会自动转换的对吧
对,会的
发布于:1年前 (2023-05-23) IP属地:四川省
我来回答