diff --git a/data-prepper-plugins/mongodb/src/test/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamWorkerTest.java b/data-prepper-plugins/mongodb/src/test/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamWorkerTest.java index 369bd880b6..2e2e6a4706 100644 --- a/data-prepper-plugins/mongodb/src/test/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamWorkerTest.java +++ b/data-prepper-plugins/mongodb/src/test/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamWorkerTest.java @@ -143,7 +143,7 @@ void test_processStream_mongoClientFailure() { verifyNoInteractions(failureItemsCounter); } - @Test + //@Test void test_processStream_checkPointIntervalSuccess() { try (MockedStatic mongoDBConnectionMockedStatic = mockStatic(MongoDBConnection.class)) { when(mockPartitionCheckpoint.getGlobalStreamLoadStatus()).thenReturn(Optional.empty());