Я запускаю переиндексацию с помощью клиента Java с 5,5 по 7,8.
ReindexRequestBuilder reIndexRequest = new ReindexRequestBuilder(client, ReindexAction.INSTANCE);
// Basic configuration
reIndexRequest.source(indexObject.getSourceIndex());
reIndexRequest.destination(indexObject.getDestinationIndex());
if (reIndex.getMaxretry() != 0) {
reIndexRequest.setMaxRetries(reIndex.getMaxretry());
}
// OpType
if (!CommonUtils.isEmpty(reIndex.getOptype())) {
reIndexRequest.request().setDestOpType(reIndex.getOptype());
}
// Script
if (!CommonUtils.isEmpty(reIndex.getScript())) {
reIndexRequest.script(new Script(reIndex.getScript()));
}
// Conflicts
reIndexRequest.abortOnVersionConflict(false);
if (reIndex.isAbortonconflict()) {
reIndexRequest.abortOnVersionConflict(reIndex.isAbortonconflict());
}
// Batch Size
if (reIndex.getBatchsize() != 0) {
reIndexRequest.request().setSourceBatchSize(reIndex.getBatchsize());
}
// Setting Refresh
if (reIndex.isRefresh()) {
reIndexRequest.refresh(reIndex.isRefresh());
}
// Method to set the max docs
if (!(reIndex.getMaxdocs() <= 0)) {
reIndexRequest.maxDocs(reIndex.getMaxdocs());
}
// Scroll
if (reIndex.getScroll() != 0) {
reIndexRequest.request().setScroll(TimeValue.timeValueMinutes(reIndex.getScroll()));
}
// Slice
if (reIndex.getSlice() != 0) {
reIndexRequest.setSlices(reIndex.getSlice());
}
где срез - 1, прокрутка - 10 и размер партии 100
Я получаю следующую ошибку,
UncategorizedExecutionException[Failed execution]; nested: IOException[Connection is closed]
Дайте мне знать, если мне нужно настроить что-то конкретное, чтобы избежать этого исключения.
Спасибо, Гарри
elasticsearch 5.5.'s
host и port в файлеelasticsearch 7.8's
elasticsearch.yml? Удалось ли вам выполнить переиндексацию образца документа через кибану? - person Opster ES Ninja - Kamal   schedule 14.07.2020