flinkcdc写入SR,报错,写入不进去

【详述】flinkcdc (dataapi方式)写入starrock写入不进去,报错如下

,本人打印出了sink的数据,oracle数据如下:
image ,但是使用flinkcdc table api 增删改都可以
【业务影响】
【StarRocks版本】SR version 2.4.0,oracle11,flink version 1.13.6 flink-connector-starrock version 1.2.3_flink-1.13_2.12
flink-connector-oracle-cdc version 2.1.1

【表模型】主键模型
【导入或者导出方式】例如:Flink
代码如下:


sr建表语句如下:
create table oracleCdcTest (
id int NOT NULL,
name string NOT NULL
) PRIMARY KEY (id)
DISTRIBUTED BY HASH(id) BUCKETS 1
PROPERTIES(“replication_num” = “3”,
“enable_persistent_index” = “true”);

sr中的建表语句请您发下

已发送,盼解决啊


你可以加这个尝试一下吗

看报错就是没有把导入源和目标的列映射上

过滤掉的数据全都是那个数据类型默认的值