diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/common/transport/NetworkExceptionHelper.java b/modules/elasticsearch/src/main/java/org/elasticsearch/common/transport/NetworkExceptionHelper.java index 71f323b596f..283df64487a 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/common/transport/NetworkExceptionHelper.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/common/transport/NetworkExceptionHelper.java @@ -52,6 +52,9 @@ public class NetworkExceptionHelper { if (e.getMessage().contains("Broken pipe")) { return true; } + if (e.getMessage().contains("Connection timed out")) { + return true; + } } return false; }