Flink StreamLoadV2 Json 数据导入失败

【详述】问题详细描述
【背景】使用flink 数据导入sr
报错信息
Error: Data quality error: Failed to iterate document stream as object. error: The JSON element does not have the requested type… Row: parser current location:

日志中Json格式 为[{},{}…]
检查发现Json格式没问题

1赞

找个在线的 json工具,把json信息贴里头格式化试试

找到问题了。flink sr connect 使用json 注意两点

  1. sinkOptions.getSinkStreamLoadProperties().put(“format”,“Json”);
    2.sinkOptions.withProperty(“sink.properties.strip_outer_array”,“true”)
    之前没加第二个参数,导致可能没把json裁剪

routine load 怎么处理呢?导入任务PAUSED。错误无法忽略

这两个配置参数加在哪呢

直接加在Flink任务的starrocks配置项上