[TEST] Use Shutdown API only if nodes are on 1.3.3 or newer to preven…

…t shutdown problems
elastic · Sep 29, 2014 · cfd9ac2 · cfd9ac2
1 parent aa89c48
commit cfd9ac2
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/test/java/org/elasticsearch/test/ExternalNode.java b/src/test/java/org/elasticsearch/test/ExternalNode.java
@@ -20,6 +20,7 @@
 
 import com.google.common.base.Predicate;
 import org.apache.lucene.util.Constants;
+import org.elasticsearch.Version;
 import org.elasticsearch.action.admin.cluster.node.info.NodeInfo;
 import org.elasticsearch.action.admin.cluster.node.info.NodesInfoResponse;
 import org.elasticsearch.client.Client;
@@ -215,8 +216,10 @@ synchronized void stop(boolean forceKill) {
         if (running()) {
             try {
                 if (forceKill == false && nodeInfo != null && random.nextBoolean()) {
-                    // sometimes shut down gracefully
-                    getClient().admin().cluster().prepareNodesShutdown(this.nodeInfo.getNode().id()).setExit(random.nextBoolean()).setDelay("0s").get();
+                    if (nodeInfo.getVersion().onOrAfter(Version.V_1_3_3)) {
+                        // sometimes shut down gracefully
+                        getClient().admin().cluster().prepareNodesShutdown(this.nodeInfo.getNode().id()).setExit(random.nextBoolean()).setDelay("0s").get();
+                    }
                 }
                 if (this.client != null) {
                     client.close();