fix test case

Signed-off-by: chenxu <[email protected]>
lakesoul-io · Sep 5, 2024 · 1a05a95 · 1a05a95
1 parent f9b0220
commit 1a05a95
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lakesoul-flink/src/test/java/org/apache/flink/lakesoul/test/fail/LakeSoulSinkFailTest.java b/lakesoul-flink/src/test/java/org/apache/flink/lakesoul/test/fail/LakeSoulSinkFailTest.java
@@ -379,7 +379,7 @@ public void testMockTableSource() throws IOException {
 
 
         streamTableEnv.executeSql(String.format(createSinkSqlFormat, resolvedSchema, "",
-                tempFolder.newFolder("testMockTableSource").getAbsolutePath(), 2,
+                tempFolder.newFolder("testMockTableSource").getAbsolutePath(),
                 resolvedSchema.getPrimaryKey().isPresent() ?
                         ", 'hashBucketNum'='2'" : ""));