iter

rjernst · Dec 6, 2024 · 119e5c7 · 119e5c7
1 parent 62d5489
commit 119e5c7
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 30 deletions.
diff --git a/...sters/src/main/java/org/elasticsearch/test/cluster/local/AbstractLocalClusterFactory.java b/...sters/src/main/java/org/elasticsearch/test/cluster/local/AbstractLocalClusterFactory.java
@@ -148,17 +148,6 @@ public Node(
         }
 
         public synchronized void start(Version version) {
-            if (process != null) {
-                // ES was previously started, so we don't need to reconfigure, just start
-                if (process.isAlive() == false) {
-                    LOGGER.info("Restarting Elasticsearch node '{}'", name);
-                    startElasticsearch();
-                    return;
-                } else {
-                    throw new AssertionError("Elasticsearch is already started");
-                }
-            }
-
             LOGGER.info("Starting Elasticsearch node '{}'", name);
             if (version != null) {
                 spec.setVersion(version);

diff --git a/...lusters/src/main/java/org/elasticsearch/test/cluster/local/DefaultLocalClusterHandle.java b/...lusters/src/main/java/org/elasticsearch/test/cluster/local/DefaultLocalClusterHandle.java
@@ -181,13 +181,6 @@ public void stopNode(int index, boolean forcibly) {
         nodes.get(index).stop(forcibly);
     }
 
-    public void restartNode(int index, boolean forcibly) {
-        Node node = nodes.get(index);
-        node.stop(forcibly);
-        node.start(null);
-        writeUnicastHostsFile();
-    }
-
     @Override
     public InputStream getNodeLog(int index, LogType logType) {
         return nodes.get(index).getLog(logType);

diff --git a/.../src/main/java/org/elasticsearch/test/cluster/local/DefaultLocalElasticsearchCluster.java b/.../src/main/java/org/elasticsearch/test/cluster/local/DefaultLocalElasticsearchCluster.java
@@ -78,12 +78,6 @@ public void stopNode(int index, boolean forcibly) {
         handle.stopNode(index, forcibly);
     }
 
-    @Override
-    public void restartNode(int index, boolean forcibly) {
-        checkHandle();
-        handle.restartNode(index, forcibly);
-    }
-
     @Override
     public void restart(boolean forcibly) {
         checkHandle();

diff --git a/.../test-clusters/src/main/java/org/elasticsearch/test/cluster/local/LocalClusterHandle.java b/.../test-clusters/src/main/java/org/elasticsearch/test/cluster/local/LocalClusterHandle.java
@@ -29,12 +29,6 @@ public interface LocalClusterHandle extends ClusterHandle {
      */
     void stopNode(int index, boolean forcibly);
 
-    /**
-     * Restarts the node by first stopping it and then starting it again.
-     * @param index of the node to stop
-     */
-    void restartNode(int index, boolean forcibly);
-
     /**
      * Restarts the cluster. Effectively the same as calling {@link #stop(boolean)} followed by {@link #start()}
      *