File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change 2626import org .elasticsearch .index .shard .ShardNotFoundException ;
2727import org .elasticsearch .index .translog .Translog ;
2828import org .elasticsearch .indices .IndexClosedException ;
29+ import org .elasticsearch .node .NodeClosedException ;
2930import org .elasticsearch .persistent .AllocatedPersistentTask ;
3031import org .elasticsearch .tasks .TaskId ;
3132import org .elasticsearch .transport .NodeDisconnectedException ;
@@ -416,6 +417,7 @@ static boolean shouldRetry(Exception e) {
416417 actual instanceof IndexClosedException || // If follow index is closed
417418 actual instanceof NodeDisconnectedException ||
418419 actual instanceof NodeNotConnectedException ||
420+ actual instanceof NodeClosedException ||
419421 (actual .getMessage () != null && actual .getMessage ().contains ("TransportService is closed" ));
420422 }
421423
You can’t perform that action at this time.
0 commit comments