diff --git a/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java b/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java index e76425a1188..a9c69007aee 100644 --- a/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java +++ b/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java @@ -111,6 +111,7 @@ public class ShardStateAction extends AbstractComponent { @Override public void handleException(TransportException exp) { + assert exp.getCause() != null : exp; if (isMasterChannelException(exp.getCause())) { waitForNewMasterAndRetry(observer, shardRoutingEntry, listener); } else {