From cba386f875ad7d5255cfadd78af2cfd40282209a Mon Sep 17 00:00:00 2001 From: Kondaka Date: Tue, 10 Oct 2023 11:16:17 -0700 Subject: [PATCH] Added debug statements to debug the failing tests Signed-off-by: Kondaka --- .../dataprepper/integration/PipelinesWithAcksIT.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/integration/PipelinesWithAcksIT.java b/data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/integration/PipelinesWithAcksIT.java index b7183d88a2..c30d39b34b 100644 --- a/data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/integration/PipelinesWithAcksIT.java +++ b/data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/integration/PipelinesWithAcksIT.java @@ -18,6 +18,7 @@ import java.util.List; import java.util.concurrent.TimeUnit; +import java.time.Instant; import static org.awaitility.Awaitility.await; import static org.hamcrest.CoreMatchers.equalTo; @@ -46,23 +47,24 @@ void setUp(String configFile) { .build(); dataPrepperTestRunner.start(); + System.out.println("Data Prepper Test started at "+Instant.now()); inMemorySourceAccessor = dataPrepperTestRunner.getInMemorySourceAccessor(); inMemorySinkAccessor = dataPrepperTestRunner.getInMemorySinkAccessor(); } @AfterEach void tearDown() { + System.out.println("Data Prepper Test stopped at "+Instant.now()); dataPrepperTestRunner.stop(); } @Test - @Disabled("Disabling because this test is flaky.") void simple_pipeline_with_single_record() { setUp(SIMPLE_PIPELINE_CONFIGURATION_UNDER_TEST); final int numRecords = 1; inMemorySourceAccessor.submit(IN_MEMORY_IDENTIFIER, numRecords); - await().atMost(2000, TimeUnit.MILLISECONDS) + await().atMost(20000, TimeUnit.MILLISECONDS) .untilAsserted(() -> { List> outputRecords = inMemorySinkAccessor.get(IN_MEMORY_IDENTIFIER); assertThat(outputRecords, not(empty())); @@ -78,7 +80,7 @@ void simple_pipeline_with_multiple_records() { final int numRecords = 100; inMemorySourceAccessor.submit(IN_MEMORY_IDENTIFIER, numRecords); - await().atMost(2000, TimeUnit.MILLISECONDS) + await().atMost(20000, TimeUnit.MILLISECONDS) .untilAsserted(() -> { List> outputRecords = inMemorySinkAccessor.get(IN_MEMORY_IDENTIFIER); assertThat(outputRecords, not(empty())); @@ -93,7 +95,7 @@ void two_pipelines_with_multiple_records() { final int numRecords = 100; inMemorySourceAccessor.submit(IN_MEMORY_IDENTIFIER, numRecords); - await().atMost(5000, TimeUnit.MILLISECONDS) + await().atMost(20000, TimeUnit.MILLISECONDS) .untilAsserted(() -> { List> outputRecords = inMemorySinkAccessor.get(IN_MEMORY_IDENTIFIER); assertThat(outputRecords, not(empty()));