diff --git a/core/src/main/java/pl/allegro/tech/embeddedelasticsearch/ElasticSearchInstaller.java b/core/src/main/java/pl/allegro/tech/embeddedelasticsearch/ElasticSearchInstaller.java index 23cc614..a861a77 100644 --- a/core/src/main/java/pl/allegro/tech/embeddedelasticsearch/ElasticSearchInstaller.java +++ b/core/src/main/java/pl/allegro/tech/embeddedelasticsearch/ElasticSearchInstaller.java @@ -128,7 +128,10 @@ private String[] prepareInstallCommand(File pluginManager, Plugin plugin) { if (installationDescription.versionIs1x() && plugin.expressionIsUrl()) { return new String[]{pluginManager.getAbsolutePath(), "--install", plugin.getPluginName(), "--url", plugin.getExpression()}; } - return new String[]{pluginManager.getAbsolutePath(), "install", plugin.getExpression()}; + if (installationDescription.versionIs1x() || installationDescription.versionIs2x()) { + return new String[]{pluginManager.getAbsolutePath(), "install", plugin.getExpression()}; + } + return new String[]{pluginManager.getAbsolutePath(), "install", "--batch", plugin.getExpression()}; } private File pluginManagerExecutable() throws IOException { diff --git a/core/src/main/java/pl/allegro/tech/embeddedelasticsearch/InstallationDescription.java b/core/src/main/java/pl/allegro/tech/embeddedelasticsearch/InstallationDescription.java index 58e9d96..1e8f24e 100644 --- a/core/src/main/java/pl/allegro/tech/embeddedelasticsearch/InstallationDescription.java +++ b/core/src/main/java/pl/allegro/tech/embeddedelasticsearch/InstallationDescription.java @@ -56,6 +56,10 @@ boolean versionIs1x() { return getVersion().startsWith("1."); } + boolean versionIs2x() { + return getVersion().startsWith("2."); + } + boolean isCleanInstallationDirectoryOnStop() { return cleanInstallationDirectoryOnStop; }