* no sniff client for now - doesn't work will all tests since it might throw NoNodeAvailableException if nodes are shut down.
* we first need support of transportClientRatio as annotations or so
*/
- transportClient = new TransportClientFactory(false, nodeConfigurationSource.transportClientSettings(), baseDir, nodeConfigurationSource.transportClientPlugins())
+ Collection<Class<? extends Plugin>> plugins = new ArrayList<>();
+ plugins.addAll(nodeConfigurationSource.transportClientPlugins());
+ plugins.addAll(mockPlugins);
+ transportClient = new TransportClientFactory(false, nodeConfigurationSource.transportClientSettings(), baseDir, plugins)
.client(node, clusterName);
}
return clientWrapper.apply(transportClient);
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.discovery.DiscoveryModule;
import org.elasticsearch.index.query.QueryBuilders;
+import org.elasticsearch.join.ParentJoinPlugin;
import org.elasticsearch.plugins.Plugin;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.test.NodeConfigurationSource;
tempDirectory = Files.createTempDirectory("es-unit-test");
tempDirectory.toFile().deleteOnExit();
cluster = new EsTestCluster(new Random().nextLong(), tempDirectory, 1, "test cluster", getNodeConfigSource(), "node-",
- Collections.emptyList(), i -> i);
+ Collections.singletonList(ParentJoinPlugin.class), i -> i);
Random random = new Random();
cluster.beforeTest(random, random.nextDouble());
cluster.wipe(NO_TEMPLATES_SURVIVING_WIPE);