From 0423cd10ce9408ccd38e9771a9c34917cddf053c Mon Sep 17 00:00:00 2001 From: Hai Yan <8153134+oeyh@users.noreply.github.com> Date: Tue, 28 Jan 2025 12:20:36 -0600 Subject: [PATCH] Disable flaky tests fow now (#5366) Signed-off-by: Hai Yan --- .../plugins/source/rds/export/DataFileSchedulerTest.java | 2 ++ .../plugins/source/rds/export/ExportSchedulerTest.java | 2 ++ .../plugins/source/rds/leader/LeaderSchedulerTest.java | 2 ++ .../plugins/source/rds/stream/StreamSchedulerTest.java | 2 ++ 4 files changed, 8 insertions(+) diff --git a/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/export/DataFileSchedulerTest.java b/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/export/DataFileSchedulerTest.java index 7f021dd7be..16e75366be 100644 --- a/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/export/DataFileSchedulerTest.java +++ b/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/export/DataFileSchedulerTest.java @@ -7,6 +7,7 @@ import io.micrometer.core.instrument.Counter; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.mockito.Mock; @@ -186,6 +187,7 @@ void test_data_file_loader_throws_exception_then_give_up_partition() { verify(sourceCoordinator).giveUpPartition(dataFilePartition); } + @Disabled("Flaky test, needs to be fixed") @Test void test_shutdown() throws InterruptedException { DataFileScheduler objectUnderTest = createObjectUnderTest(); diff --git a/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/export/ExportSchedulerTest.java b/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/export/ExportSchedulerTest.java index 780078e490..a0759c496c 100644 --- a/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/export/ExportSchedulerTest.java +++ b/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/export/ExportSchedulerTest.java @@ -8,6 +8,7 @@ import io.micrometer.core.instrument.Counter; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.mockito.Answers; @@ -261,6 +262,7 @@ void test_given_export_partition_and_null_export_task_id_then_close_partition_wi verify(exportS3ObjectsTotalCounter, never()).increment(1); } + @Disabled("Flaky test, needs to be fixed") @Test void test_shutDown() throws InterruptedException { lenient().when(sourceCoordinator.acquireAvailablePartition(ExportPartition.PARTITION_TYPE)).thenReturn(Optional.empty()); diff --git a/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/leader/LeaderSchedulerTest.java b/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/leader/LeaderSchedulerTest.java index 0277258ac9..060e3e9a29 100644 --- a/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/leader/LeaderSchedulerTest.java +++ b/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/leader/LeaderSchedulerTest.java @@ -6,6 +6,7 @@ package org.opensearch.dataprepper.plugins.source.rds.leader; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.mockito.Answers; @@ -128,6 +129,7 @@ void leader_node_should_skip_init_if_initialized() throws InterruptedException { verify(sourceCoordinator).saveProgressStateForPartition(eq(leaderPartition), any(Duration.class)); } + @Disabled("Flaky test, needs to be fixed") @Test void test_shutDown() { lenient().when(sourceCoordinator.acquireAvailablePartition(LeaderPartition.PARTITION_TYPE)).thenReturn(Optional.empty()); diff --git a/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamSchedulerTest.java b/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamSchedulerTest.java index 325be414d9..38e78efd59 100644 --- a/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamSchedulerTest.java +++ b/data-prepper-plugins/rds-source/src/test/java/org/opensearch/dataprepper/plugins/source/rds/stream/StreamSchedulerTest.java @@ -6,6 +6,7 @@ package org.opensearch.dataprepper.plugins.source.rds.stream; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.mockito.Answers; @@ -115,6 +116,7 @@ void test_given_stream_partition_then_start_stream() throws InterruptedException verify(pluginConfigObservable).addPluginConfigObserver(any(PluginConfigObserver.class)); } + @Disabled("Flaky test, needs to be fixed") @Test void test_shutdown() throws InterruptedException { lenient().when(sourceCoordinator.acquireAvailablePartition(StreamPartition.PARTITION_TYPE)).thenReturn(Optional.empty());