【详述】flink写starrocks报错
【导入/导出方式】flink
【StarRocks版本】sr：2.4.0，flink-connector：1.2.2_flink-1.14_2.12
【集群规模】例如：3fe（3 follower）+3be（fe与be混部）
【机器信息】8+32
建表语句：
CREATE TABLE customerrelationcustomlabelinfo (
mainshopnick varchar(65533) NOT NULL COMMENT “”,
buyernick varchar(65533) NOT NULL COMMENT “”,
id bigint(20) NOT NULL COMMENT “”,
labelid bigint(20) NULL COMMENT “”,
labelvalue varchar(65533) NULL COMMENT “”,
shoptype int(11) NULL COMMENT “”,
shopid bigint(20) NULL COMMENT “”,
expiretype int(11) NULL COMMENT “”,
expiretime datetime NULL COMMENT “”,
source varchar(65533) NULL COMMENT “”,
isdelete int(11) NULL COMMENT “”,
createtime datetime NULL COMMENT “”,
updatetime datetime NULL COMMENT “”
) ENGINE=OLAP
PRIMARY KEY(mainshopnick, buyernick, id)
COMMENT “OLAP”
DISTRIBUTED BY HASH(id) BUCKETS 200
PROPERTIES (
“replication_num” = “3”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “true”
);
flink sink的配置
flink报错信息：
在flink-connector打印数据：
