protect against transport shutdowns

2016-02-12 10:22:54 +01:00 · 2016-02-12 10:22:54 +01:00 · 57501ce5ff
parent 74194b8f0f
commit 57501ce5ff
1 changed files with 2 additions and 1 deletions
--- a/core/src/main/java/org/elasticsearch/action/support/replication/TransportReplicationAction.java
+++ b/core/src/main/java/org/elasticsearch/action/support/replication/TransportReplicationAction.java
@ -995,7 +995,8 @@ public abstract class TransportReplicationAction<Request extends ReplicationRequ
                                                indexShardReference.failShard(message, shardFailedError);
                                                forceFinishAsFailed(new RetryOnPrimaryException(shardId, message, shardFailedError));
                                            } else {
-                                                assert false : shardFailedError;
+                                                assert shardFailedError.getMessage().contains("TransportService is closed ") :
+                                                        shardFailedError;
                                                onReplicaFailure(nodeId, exp);
                                            }
                                        }