flinksql导入,数据中有%导致报错,Unable to flush data to StarRocks:

insert的字段中包含%,导入报这个错误
Unable to flush data to StarRocks: unknown result status, usually caused by authentication or permission related problems.]

请问哪个版本?麻烦把您的finksql发下

drop table if exists wms_out_sorting_operator_record_rt2;
create table wms_out_sorting_operator_record_rt2 (
id bigint
,warehouse_id bigint
,expt_shipped_date string
,sorting_header_id bigint
,sorting_detail_id bigint
,sku_id bigint
,sku_name varchar
) WITH (

‘connector’ = ‘starrocks’,
‘jdbc-url’ = ‘jdbc:mysql://xxx:9030?test’,
‘load-url’ = ‘xxx:8030’,
‘database-name’ = ‘test’,
‘table-name’ = ‘table1’,
‘username’ = ‘xxx’,
‘password’ = ‘xxx’,
‘sink.semantic’ = ‘exactly-once’,
‘sink.max-retries’ = ‘3’,
‘sink.buffer-flush.interval-ms’ = ‘60000’,
‘sink.buffer-flush.max-bytes’ = ‘94371840’,
‘sink.buffer-flush.max-rows’ = ‘64000’
)

insert into wms_out_sorting_operator_record_rt2
select cast(after[‘id’] as bigint) as id
,cast(after[‘warehouse_id’] as bigint) as warehouse_id
,after[‘expt_shipped_date’] as expt_shipped_date
,cast(after[‘sorting_header_id’] as bigint) as sorting_header_id
,cast(after[‘sorting_detail_id’] as bigint) as sorting_detail_id
,cast(after[‘sku_id’] as bigint) as sku_id
,after[‘sku_name’] as sku_name
from wms_source2

sku_name 里面有100%字样

您好,请问哪个版本,去掉%可以导入对吗

您好,辛苦把报错的上下文日志都发来吧

去掉可以,或者转成%25也可以

您好,麻烦把flink taskmanager日志和您截图附近日志都发来吧

方便发下taskmanager的日志吗?

我按照这个表的定义跑了一个Flink作业,但是没有复现,sku_name的值为"100%"。方便发一下出问题的数据吗?你的connector是哪个版本?taskmanager日志也麻烦发下,看看有没有其它异常信息