flink sql 导入数据报错

【详述】flink sql导数据报错
【背景】
【业务影响】
【StarRocks版本】例如：1.19.1
【集群规模】例如：3fe（1 follower+2observer）+3be（fe与be混部）
【机器信息】CPU虚拟核/内存，例如：8C/32G
【附件】
建表部分语句
with (
‘username’ = ‘dorisdb’,
‘jdbc-url’ = ‘jdbc:mysql://172.26.16.25:9030’,
‘sink.properties.row_delimiter’ = ‘\x02’,
‘database-name’ = ‘airdroid_sts’,
‘table-name’ = ‘client_login_logs’,
‘sink.buffer-flush.interval-ms’ = ‘15000’,
‘connector’ = ‘starrocks’,
‘sink.properties.strip_outer_array’ = ‘true’,
‘sink.properties.column_separator’ = ‘\x01’,
‘sink.properties.format’ = ‘json’,
‘password’ = ‘123456’,
‘load-url’ = ‘172.26.16.25:8030’
);

flink 报错信息

微信图片_202112061521441368×604 84.7 KB

涉及日志

error_log_insert_stmt_81434836-a16f-ef09-9ea2-ec9e34a2b386_81434836a16fef09_9ea2ec9e34a2b386 (64.1 KB)

在服务器上curl一下errorurl，里面有报错的详细信息

我上面附件的日志，就是相关日志，但是只有部分，里面大部分信息都是html class配置。另外日志信息超出长度了，截图是最后几行

image1629×903 8.39 KB

字段长度过长了，目前最大长度支持65535，如果不是实际字段长度过长引起的异常，则可能是因为没有指定分隔符。 加上
.withProperty(“sink.properties.column_separator”, “\x01”)
.withProperty(“sink.properties.row_delimiter”, “\x02”)
两个参数
或者加上
.withProperty(“sink.properties.format”, “json”)
.withProperty(“sink.properties.strip_outer_array”, “true”)
这两参数。
详情参考https://docs.starrocks.com/zh-cn/main/loading/Flink-connector-starrocks#%E4%BD%BF%E7%94%A8%E6%96%B9%E5%BC%8F

这些我都配置上了，
‘sink.properties.format’ = ‘json’,
‘sink.properties.strip_outer_array’ = ‘true’,
‘sink.properties.row_delimiter’ = ‘\x02’,
‘sink.properties.column_separator’ = ‘\x01’,
或者一个斜杆的
‘sink.properties.format’ = ‘json’,
‘sink.properties.strip_outer_array’ = ‘true’,
‘sink.properties.row_delimiter’ = ‘\x02’,
‘sink.properties.column_separator’ = ‘\x01’,

我都试了，但是都报类似的错误

这两组参数配置一组就可以了，不需要重复配置，把
.withProperty(“sink.properties.column_separator”, “\x01”)
.withProperty(“sink.properties.row_delimiter”, “\x02”)
这两参数删掉把