|
@@ -64,6 +64,7 @@ import org.elasticsearch.test.transport.StubbableConnectionManager;
|
|
|
import org.elasticsearch.test.transport.StubbableTransport;
|
|
|
import org.elasticsearch.threadpool.TestThreadPool;
|
|
|
import org.elasticsearch.threadpool.ThreadPool;
|
|
|
+import org.junit.Before;
|
|
|
|
|
|
import java.io.IOException;
|
|
|
import java.net.InetAddress;
|
|
@@ -111,6 +112,13 @@ public class RemoteClusterConnectionTests extends ESTestCase {
|
|
|
ThreadPool.terminate(threadPool, 10, TimeUnit.SECONDS);
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ @Before
|
|
|
+ public void setUp() throws Exception {
|
|
|
+ super.setUp();
|
|
|
+ assumeFalse("https://github.com/elastic/elasticsearch/issues/44339", System.getProperty("os.name").contains("Win"));
|
|
|
+ }
|
|
|
+
|
|
|
private MockTransportService startTransport(String id, List<DiscoveryNode> knownNodes, Version version) {
|
|
|
return startTransport(id, knownNodes, version, threadPool);
|
|
|
}
|
|
@@ -178,7 +186,6 @@ public class RemoteClusterConnectionTests extends ESTestCase {
|
|
|
}
|
|
|
|
|
|
public void testRemoteProfileIsUsedForLocalCluster() throws Exception {
|
|
|
- assumeFalse("https://github.com/elastic/elasticsearch/issues/44339", System.getProperty("os.name").contains("Win"));
|
|
|
List<DiscoveryNode> knownNodes = new CopyOnWriteArrayList<>();
|
|
|
try (MockTransportService seedTransport = startTransport("seed_node", knownNodes, Version.CURRENT);
|
|
|
MockTransportService discoverableTransport = startTransport("discoverable_node", knownNodes, Version.CURRENT)) {
|
|
@@ -456,7 +463,6 @@ public class RemoteClusterConnectionTests extends ESTestCase {
|
|
|
}
|
|
|
|
|
|
public void testConnectWithIncompatibleTransports() throws Exception {
|
|
|
- assumeFalse("https://github.com/elastic/elasticsearch/issues/44339", System.getProperty("os.name").contains("Win"));
|
|
|
List<DiscoveryNode> knownNodes = new CopyOnWriteArrayList<>();
|
|
|
try (MockTransportService seedTransport = startTransport("seed_node", knownNodes, Version.fromString("2.0.0"))) {
|
|
|
DiscoveryNode seedNode = seedTransport.getLocalDiscoNode();
|