diff options
author | Simon Willnauer <simonw@apache.org> | 2017-07-02 22:12:35 +0200 |
---|---|---|
committer | Simon Willnauer <simonw@apache.org> | 2017-07-02 22:12:35 +0200 |
commit | 12056100233fef70b20c498fa8c9d7917dca2ffa (patch) | |
tree | 29d2c20176c7bb873d329a730cc395ac8dc96427 /core/src/test/java/org/elasticsearch | |
parent | a4fae1540ea14331467199309d4eb7551a91f700 (diff) |
[TEST] Expect nodes getting disconnected quickly
If all nodes get disconnected before we can send the request we might
try to reconnect and that will fail with an ISE instead of the a transport
exception.
Closes #25301
Diffstat (limited to 'core/src/test/java/org/elasticsearch')
-rw-r--r-- | core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java b/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java index 646efa9428..1dbd935229 100644 --- a/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java +++ b/core/src/test/java/org/elasticsearch/transport/RemoteClusterServiceTests.java @@ -410,12 +410,16 @@ public class RemoteClusterServiceTests extends ESTestCase { }); failLatch.await(); assertNotNull(ex.get()); - if (ex.get() instanceof TransportException == false) { - // we have an issue for this see #25301 - logger.error("expected TransportException but got a different one see #25301", ex.get()); + if (ex.get() instanceof IllegalStateException) { + assertEquals(ex.get().getMessage(), "no seed node left"); + } else { + if (ex.get() instanceof TransportException == false) { + // we have an issue for this see #25301 + logger.error("expected TransportException but got a different one see #25301", ex.get()); + } + assertTrue("expected TransportException but got a different one [" + ex.get().getClass().toString() + "]", + ex.get() instanceof TransportException); } - assertTrue("expected TransportException but got a different one [" + ex.get().getClass().toString() + "]", - ex.get() instanceof TransportException); } } } |