http方式发送json数据到starrocks报错

[17688807265]

【详述】问题详细描述

自己写了一段代码，通过http的方式发送一条json数据到be，但是报错了。同样的数据，通过flink connector的方式，写入成功，我的代码是根据flink connector的源码写的，请问问题出在哪里？

【导入/导出方式】

自定义http方式

【背景】做过哪些操作？

无

【业务影响】

数据写入失败

【StarRocks版本】例如：

2.1

【集群规模】例如：3fe（1 follower+2observer）+5be（fe与be混部）

1fe，3be

【机器信息】CPU虚拟核/内存/网卡，例如：48C/64G/万兆

8核64g
【附件】

[mark]

错误的url有吗？

[17688807265]

[17688807265]

这个是错误的日志

[mark]

看起来是分隔符的问题，json格式有这2个参数吗？
sink.sink.properties.format=json
sink.sink.properties.strip_outer_array=true

[17688807265]

设置了这两个参数：

HttpPut httpPut = new HttpPut(loadUrl);
httpPut.setHeader(“sink.properties.format”, “json”);
httpPut.setHeader(“sink.properties.row_delimiter”, “,”);
httpPut.setHeader(“sink.properties.strip_outer_array”, “true”);

  if (!httpPut.containsHeader("timeout")) {
    httpPut.setHeader("timeout", "60");
  }
  httpPut.setHeader("Expect", "100-continue");
  httpPut.setHeader("label", label);
  httpPut.setHeader("Authorization", authorization);

[U_1629429702833_3792]

不需要设置row_delimiter。。。