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
index e44d53803..feb5cc53d 100644
--- 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'" : ""));