Upgrade Snowflake to 2.1.2 - Add testNominalInsert with different off…

…sets to allow duplicates insert in snowflake.
streamkap-com · Feb 5, 2024 · adb6d5b · adb6d5b
1 parent 18828b2
commit adb6d5b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/test/java/com/snowflake/kafka/connector/SnowflakeStreamkapSinkIT.java b/src/test/java/com/snowflake/kafka/connector/SnowflakeStreamkapSinkIT.java
@@ -100,7 +100,7 @@ protected boolean checkTableMetadata() {
 
     @Test
     public void testNominal() throws SQLException, InterruptedException {
-        super.testNominalInsert(false);
+        super.testNominalInsert(false, 1);
     }
 
     // @Test

diff --git a/src/test/java/com/snowflake/kafka/connector/StreamkapITSnowflake.java b/src/test/java/com/snowflake/kafka/connector/StreamkapITSnowflake.java
@@ -110,7 +110,7 @@ protected boolean checkTableMetadata() {
 
     @Test
     public void testNominal() throws SQLException, InterruptedException {
-        super.testNominalInsert(false);
+        super.testNominalInsert(false, 1);
     }
 
     // @Test