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日志也麻烦发下,看看有没有其它异常信息

