Skip to content

Commit e11b2b7

Browse files
committed
CCR: Add NodeClosedException to retryable list (#35191)
This change adds NodeClosedException to the retry-able exception list.
1 parent 2fd0887 commit e11b2b7

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowNodeTask.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.elasticsearch.index.shard.ShardNotFoundException;
2727
import org.elasticsearch.index.translog.Translog;
2828
import org.elasticsearch.indices.IndexClosedException;
29+
import org.elasticsearch.node.NodeClosedException;
2930
import org.elasticsearch.persistent.AllocatedPersistentTask;
3031
import org.elasticsearch.tasks.TaskId;
3132
import 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

0 commit comments

Comments
 (0)