Remove useless test.

Signed-off-by: Marc Handalian <handalm@amazon.com>
opensearch-project · Aug 28, 2023 · 3608f50 · 3608f50
1 parent 5e52b02
commit 3608f50
Showing 1 changed file with 0 additions and 30 deletions.
diff --git a/server/src/test/java/org/opensearch/index/engine/NRTReplicationEngineTests.java b/server/src/test/java/org/opensearch/index/engine/NRTReplicationEngineTests.java
@@ -203,36 +203,6 @@ public void testSimultaneousEngineCloseAndCommit() throws IOException, Interrupt
         }
     }
 
-    public void testSimultaneousFlushAndCommit() throws IOException, InterruptedException {
-        final AtomicLong globalCheckpoint = new AtomicLong(SequenceNumbers.NO_OPS_PERFORMED);
-        try (
-            final Store nrtEngineStore = createStore(INDEX_SETTINGS, newDirectory());
-            final NRTReplicationEngine nrtEngine = buildNrtReplicaEngine(globalCheckpoint, nrtEngineStore)
-        ) {
-            CountDownLatch latch = new CountDownLatch(1);
-            Thread commitThread = new Thread(() -> {
-                try {
-                    nrtEngine.updateSegments(store.readLastCommittedSegmentsInfo());
-                    latch.countDown();
-                } catch (IOException e) {
-                    throw new RuntimeException(e);
-                }
-            });
-            Thread closeThread = new Thread(() -> {
-                try {
-                    latch.await();
-                    nrtEngine.flush(true, true);
-                } catch (InterruptedException e) {
-                    throw new RuntimeException(e);
-                }
-            });
-            commitThread.start();
-            closeThread.start();
-            commitThread.join();
-            closeThread.join();
-        }
-    }
-
     public void testUpdateSegments_replicaCommitsFirstReceivedInfos() throws IOException {
         final AtomicLong globalCheckpoint = new AtomicLong(SequenceNumbers.NO_OPS_PERFORMED);