【详述】用flink CDC同步mongoDB的数据，用默认的csv格式同步，报错Target column count: 4 doesn’t match source value column count: 3。但是改成json格式再同步，就没有报错
【背景】检查了原始数据，除分隔符外无其他的/t，检查了starrocks的表也只有3个字段
【业务影响】影响数据同步
【是否存算分离】否
【StarRocks版本】3.3.14
【集群规模】3fe+3be混合部署
【机器信息】4核16G
【附件】
报错信息
Caused by: java.lang.RuntimeException: com.starrocks.data.load.stream.exception.StreamLoadFailException: Transaction prepare failed, db: tauc_info_dev, table: mongodb_tpuc_traccess_device_component, label: flink-83a0aae8-f21e-472b-9ee9-0306be4323ce,
responseBody: {
"Status": "INTERNAL_ERROR",
"Message": "too many filtered rows",
"ErrorURL": "http://10.53.151.195:8040/api/_load_error_log?file=error_log_5f4aaf72ebdfad4e_fc5a1fdd2a4564ab"
}
errorLog: Error: Target column count: 4 doesn't match source value column count: 3. Column separator: '\t', Row delimiter: '\n'. Row: 686db517867b3f0d32dcd462 2887BA-Device2-22244P2000220 [{"n":"ewan" , "v":"1.0"},{"n":"inet_v4" , "v":"1.0"},{"n":"inet_v6" , "v":"1.0"},{"n":"intf_bd" , "v":"1.0"},{"n":"dft_gw" , "v":"1.0"},{"n":"pptp" , "v":"1.0"},{"n":"l2tp" , "v":"1.0"},{"n":"macvlan" , "v":"2.0"},{"n":"v6Pstr" , "v":"1.0"},{"n":"lan_ip" , "v":"1.0"},{"n":"lan_dhcp" , "v":"1.0"},{"n":"ddns" , "v":"1.0"},{"n":"stc_rt" , "v":"1.0"},{"n":"rip_rt" , "v":"1.0"},{"n":"tun" , "v":"1.0"},{"n":"alg" , "v":"1.0"},{"n":"vs" , "v":"1.0"},{"n":"pt_trig" , "v":"1.0"},{"n":"dmz" , "v":"1.0"},{"n":"upnp" , "v":"1.0"},{"n":"pc" , "v":"1.0"},{"n":"lock" , "v":"1.0"},{"n":"scy" , "v":"1.0"},{"n":"vpn" , "v":"1.0"},{"n":"iqos" , "v":"1.0"},{"n":"iqos_limit" , "v":"1.0"},{"n":"mld_pxy" , "v":"1.0"},{"n":"diag" , "v":"1.0"},{"n":"wl_scan" , "v":"1.0"},{"n":"oper_md" , "v":"1.0"},{"n":"mimo" , "v":"1.0"},{"n":"11r" , "v":"1.0"},{"n":"atf" , "v":"1.0"},{"n":"11ax" , "v":"1.0"},{"n":"wpa3" , "v":"1.0"},{"n":"wl_sch" , "v":"1.0"},{"n":"wl" , "v":"1.0"},{"n":"wps" , "v":"1.0"},{"n":"wl_spec" , "v":"1.0"},{"n":"time" , "v":"1.0"},{"n":"led" , "v":"1.0"},{"n":"spd_tst" , "v":"1.0"},{"n":"fw" , "v":"1.0"},{"n":"bkup" , "v":"1.0"},{"n":"rb_sch" , "v":"1.0"},{"n":"adm" , "v":"1.0"},{"n":"sys_log" , "v":"1.0"},{"n":"cwmp" , "v":"1.0"},{"n":"snmp" , "v":"1.0"},{"n":"trf_sts" , "v":"1.0"},{"n":"dev" , "v":"1.0"},{"n":"cl" , "v":"2.0"},{"n":"mesh" , "v":"1.0"},{"n":"otg_determ" , "v":"1.0"},{"n":"apsteer" , "v":"1.0"},{"n":"cl_l" , "v":"1.0"},{"n":"tr_tree" , "v":"1.0"},{"n":"ookla" , "v":"2.0"},{"n":"samknows" , "v":"1.0"},{"n":"spd_repo" , "v":"1.0"},{"n":"clientRoaming" , "v":"1.0"},{"n":"pin6" , "v":"1.0"},{"n":"tra6" , "v":"1.0"},{"n":"agc_web" , "v":"1.0"},{"n":"logctr" , "v":"1.0"},{"n":"cr" , "v":"1.0"},{"n":"rmtmng" , "v":"2.0"},{"n":"cln_cfg" , "v":"1.0"}]
