elastic/elasticsearch

Make SnapshotHistoryStore retry indexing history data on EsRejectedExecutionException

Open

#141.887 aberto em 4 de fev. de 2026

Ver no GitHub
 (7 comments) (0 reactions) (0 assignees)Java (76.700 stars) (25.882 forks)batch import
:Distributed/SLM>bugTeam:Distributedgood first issue

Description

ILMHistoryStore uses BulkProcessor to retry indexing history up to 3 times if it hits a EsRejectedExecutionException because the cluster was too busy. From what I can tell, SnapshotHistoryStore just makes a single attempt, and logs an error and moves on if it hits EsRejectedExecutionException. I have seen this several times in production logs. We ought to have SnapshotHistoryStore use BulkProcessor to make a few attempts before giving up.

Guia do colaborador

Pilha de tecnologia
java
Domain
backenddata
Tipo Issue
bug
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
1-3 hours
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
active
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
clear
Prerequisites
JavaElasticsearch source code setup
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
70
Direção de pesquisa
The issue references ILMHistoryStore.java (line 167) using BulkProcessor to retry indexing, while SnapshotHistoryStore.java (line 82) only makes a single attempt. The solution involves adding a similar BulkProcessor with retry logic to SnapshotHistoryStore. Examine the existing ILMHistoryStore implementation and adapt it, ensuring to handle EsRejectedExecutionException properly. Integration tests should be included to verify the retry behavior.