From 8c428409e9cc842cec38f522d51818158c9d1bc4 Mon Sep 17 00:00:00 2001 From: subodh Date: Mon, 26 Sep 2022 17:24:27 +0530 Subject: [PATCH] fix test --- .../source/jdbc/test/JdbcSourceAcceptanceTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/airbyte-integrations/connectors/source-jdbc/src/testFixtures/java/io/airbyte/integrations/source/jdbc/test/JdbcSourceAcceptanceTest.java b/airbyte-integrations/connectors/source-jdbc/src/testFixtures/java/io/airbyte/integrations/source/jdbc/test/JdbcSourceAcceptanceTest.java index fb4afdf0678c..54a10f609e3f 100644 --- a/airbyte-integrations/connectors/source-jdbc/src/testFixtures/java/io/airbyte/integrations/source/jdbc/test/JdbcSourceAcceptanceTest.java +++ b/airbyte-integrations/connectors/source-jdbc/src/testFixtures/java/io/airbyte/integrations/source/jdbc/test/JdbcSourceAcceptanceTest.java @@ -355,8 +355,9 @@ protected void testDiscoverWithNullableCursorFields() throws Exception { actual.getStreams().stream().filter(s -> s.getName().equalsIgnoreCase(TABLE_NAME_WITH_NULLABLE_CURSOR_TYPE)).findFirst().orElse(null); assertNotNull(stream); assertEquals(TABLE_NAME_WITH_NULLABLE_CURSOR_TYPE.toLowerCase(), stream.getName().toLowerCase()); - assertEquals(1, stream.getSupportedSyncModes().size()); - assertEquals(SyncMode.FULL_REFRESH, stream.getSupportedSyncModes().get(0)); + assertEquals(2, stream.getSupportedSyncModes().size()); + assertTrue(stream.getSupportedSyncModes().contains(SyncMode.FULL_REFRESH)); + assertTrue(stream.getSupportedSyncModes().contains(SyncMode.INCREMENTAL)); } protected AirbyteCatalog filterOutOtherSchemas(final AirbyteCatalog catalog) {