move index creation out of setup.

Signed-off-by: Rishikesh1159 <[email protected]>
Rishikesh1159 · Oct 18, 2023 · 10b94f1 · 10b94f1
1 parent 267bd5a
commit 10b94f1
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...nternalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationSuiteIT.java b/...nternalClusterTest/java/org/opensearch/indices/replication/SegmentReplicationSuiteIT.java
@@ -21,7 +21,6 @@ public class SegmentReplicationSuiteIT extends SegmentReplicationBaseIT {
     @Before
     public void setup() {
         internalCluster().startClusterManagerOnlyNode();
-        createIndex(INDEX_NAME);
     }
 
     @Override
@@ -38,6 +37,7 @@ public Settings indexSettings() {
     }
 
     public void testBasicReplication() throws Exception {
+        createIndex(INDEX_NAME);
         final int docCount = scaledRandomIntBetween(10, 200);
         for (int i = 0; i < docCount; i++) {
             client().prepareIndex(INDEX_NAME).setId(Integer.toString(i)).setSource("field", "value" + i).execute().get();
@@ -50,6 +50,7 @@ public void testBasicReplication() throws Exception {
     public void testDropRandomNodeDuringReplication() throws Exception {
         internalCluster().ensureAtLeastNumDataNodes(2);
         internalCluster().startClusterManagerOnlyNodes(1);
+        createIndex(INDEX_NAME);
 
         final int docCount = scaledRandomIntBetween(10, 200);
         for (int i = 0; i < docCount; i++) {
@@ -67,6 +68,7 @@ public void testDropRandomNodeDuringReplication() throws Exception {
 
     public void testDeleteIndexWhileReplicating() throws Exception {
         internalCluster().startClusterManagerOnlyNode();
+        createIndex(INDEX_NAME);
         final int docCount = scaledRandomIntBetween(10, 200);
         for (int i = 0; i < docCount; i++) {
             client().prepareIndex(INDEX_NAME).setId(Integer.toString(i)).setSource("field", "value" + i).execute().get();
@@ -77,6 +79,7 @@ public void testDeleteIndexWhileReplicating() throws Exception {
 
     public void testFullRestartDuringReplication() throws Exception {
         internalCluster().startNode();
+        createIndex(INDEX_NAME);
         final int docCount = scaledRandomIntBetween(10, 200);
         for (int i = 0; i < docCount; i++) {
             client().prepareIndex(INDEX_NAME).setId(Integer.toString(i)).setSource("field", "value" + i).execute().get();