Doris写入数据异常提示actual column number in csv file is less than schema column number

Flink 写入Doris报错

1
Reason: actual column number in csv file is  less than  schema column number.actual number: 34, column separator: [	], line delimiter: [].......

通过去掉列中的换行和回车,修正了部分问题

原格式:

1
2
3
select 
VERSION_J as VERSION_J
from t

修改后:

1
2
3
select 
REGEXP_REPLACE(coalesce(VERSION_J, ''),'CHAR(13)|CHAR(10)|\r|\n','') as VERSION_J
from t