UncategorizedExecutionException [Неудачное выполнение]; вложенный: IOException [Соединение закрыто] - ElasticSearch - PullRequest
Новая
       83

UncategorizedExecutionException [Неудачное выполнение]; вложенный: IOException [Соединение закрыто] - ElasticSearch

1 голос
/ 11 июля 2020

Я запускаю переиндексирование с использованием клиента 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]

Дайте мне знать, если мне нужно настроить что-то конкретное c, чтобы избежать этого исключения.

Спасибо, Гарри

...