Mark the DocumentMigration EndToEndTest (which is different than the …

…MetadataMigration test of the same name) as isolated. I've also bumped a timeout up on a network test. Signed-off-by: Greg Schohn <[email protected]>
gregschohn · Sep 12, 2024 · eb334ca · eb334ca
1 parent 3810480
commit eb334ca
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/DocumentsFromSnapshotMigration/src/test/java/com/rfs/EndToEndTest.java b/DocumentsFromSnapshotMigration/src/test/java/com/rfs/EndToEndTest.java
@@ -6,6 +6,7 @@
 import java.util.concurrent.CompletableFuture;
 
 import org.hamcrest.Matchers;
+import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.io.TempDir;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ArgumentsSource;
@@ -27,6 +28,7 @@
 import static org.hamcrest.CoreMatchers.equalTo;
 import static org.hamcrest.MatcherAssert.assertThat;
 
+@Tag("isolatedTest")
 public class EndToEndTest extends SourceTestBase {
     @TempDir
     private File localDirectory;

diff --git a/...est/java/org/opensearch/migrations/replay/datahandlers/NettyPacketToHttpConsumerTest.java b/...est/java/org/opensearch/migrations/replay/datahandlers/NettyPacketToHttpConsumerTest.java
@@ -440,7 +440,7 @@ public void testResponseTakesLongerThanTimeout(boolean useTls) throws Exception
                 Instant.now(),
                 Instant.now(),
                 () -> Stream.of(EXPECTED_REQUEST_STRING.getBytes(StandardCharsets.UTF_8)));
-            var maxTimeToWaitForTimeoutOrResponse = Duration.ofSeconds(10);
+            var maxTimeToWaitForTimeoutOrResponse = Duration.ofSeconds(30);
             var aggregatedResponse = requestFinishFuture.get(maxTimeToWaitForTimeoutOrResponse);
             log.atInfo().setMessage("RequestFinishFuture finished").log();
             Assertions.assertInstanceOf(ReadTimeoutException.class, aggregatedResponse.getError());