Ошибка эластичного массового индекса от Java-клиента ⇐ JAVA

[Anonymous]

Я пытаюсь массово индексировать свою резинку как услугу, используя этот код:

Код: Выделить всё

            List listIndexOperations = productionList.stream()
.map(production -> BulkOperation.of(bulkOpBuilder -> bulkOpBuilder
.index(indexOpBuilder -> indexOpBuilder
.id(production.getId().toString())
.document(production)
)
))
.collect(Collectors.toList());
BulkRequest bulkRequest = BulkRequest.of(buckBuilder -> buckBuilder
.index(indexName)
.operations(listIndexOperations)
);
getElasticsearchClient().bulk(bulkRequest);

Он работает нормально, когда я развертываю приложение в k8s и запускаю его, НО когда я пытаюсь запустить его из локальной среды (Windows), я получаю ошибку:

Код: Выделить всё

"type":"illegal_argument_exception","reason":"Malformed action/metadata line [3], expected START_OBJECT but found [VALUE_STRING]

С другой стороны, индексация одного элемента работает нормально в обоих случаях:

Код: Выделить всё

            getElasticsearchClient().index(indexReqBuilder -> indexReqBuilder.index(getAliasName())
.id(String.valueOf(productionToIndex.getId()))
.document(productionToIndex));

Есть идеи, почему массовый индекс не работает на моем локальном компьютере?

Подробнее здесь: https://stackoverflow.com/questions/786 ... ava-client