Apache NIFI - Putelasticsearch - 内容格式错误，解析后发现额外数据：START_OBJECT
Apache NIFI - Putelasticsearch - Malformed content, found extra data after parsing: START_OBJECT
我正在使用 Putelasticsearch5 处理器，而且我的上游处理器很少。
来自上游处理器的结果 json 如下所示：
{"id":"1234","name":"apple"}
{"id":"5678","name":"Orange"}
我希望它能做一个批量索引。但是它抛出错误说 "Caused by: java.lang.IllegalArgumentException: Malformed content, found extra data after parsing: START_OBJECT"
我做错了什么？
PutElasticsearch 处理器自动将单个文档捆绑到批量 API 中。这意味着（PutElasticsearchHttpRecord 除外）他们希望每个流文件有一个文档，您可以尝试通过设置 Batch Size 属性 来对它们进行批处理。例如，如果将批处理大小设置为 100，则处理器将处理接下来的 100 个流文件（即当处理器被触发时队列中有多少流文件——最多 100 个）。
如果您有 MergeContent 处理器或将所有文档捆绑在一起的东西，请尝试删除该部分流程。如果您发现性能问题，请尝试降低 PutElasticsearch 处理器的调度频率或将 运行 持续时间设置为 25 毫秒或更长。
我正在使用 Putelasticsearch5 处理器，而且我的上游处理器很少。
来自上游处理器的结果 json 如下所示： {"id":"1234","name":"apple"} {"id":"5678","name":"Orange"}
我希望它能做一个批量索引。但是它抛出错误说 "Caused by: java.lang.IllegalArgumentException: Malformed content, found extra data after parsing: START_OBJECT"
我做错了什么？
PutElasticsearch 处理器自动将单个文档捆绑到批量 API 中。这意味着（PutElasticsearchHttpRecord 除外）他们希望每个流文件有一个文档，您可以尝试通过设置 Batch Size 属性 来对它们进行批处理。例如，如果将批处理大小设置为 100，则处理器将处理接下来的 100 个流文件（即当处理器被触发时队列中有多少流文件——最多 100 个）。
如果您有 MergeContent 处理器或将所有文档捆绑在一起的东西，请尝试删除该部分流程。如果您发现性能问题，请尝试降低 PutElasticsearch 处理器的调度频率或将 运行 持续时间设置为 25 毫秒或更长。