Revert "fix flink test case"

This reverts commit 9d0d7df.
lakesoul-io · Sep 5, 2024 · 4dae785 · 4dae785
1 parent 9d0d7df
commit 4dae785
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/...nk/src/test/java/org/apache/flink/lakesoul/test/connector/sink/LakeSoulTableSinkCase.java b/...nk/src/test/java/org/apache/flink/lakesoul/test/connector/sink/LakeSoulTableSinkCase.java
@@ -297,6 +297,9 @@ private void testLakeSoulTableSinkWithParallelismBase(
                                 + " real_col int"
                                 + ") WITH ("
                                 + "'"
+                                + HASH_BUCKET_NUM.key()
+                                + "'= '3',"
+                                + "'"
                                 + LAKESOUL_TABLE_PATH.key()
                                 + "'='" +
                                 getTempDirUri("/test_table")
@@ -335,6 +338,9 @@ private void testLakeSoulTableSinkDeleteWithParallelismBase(
                                 + " PARTITIONED BY ( part )"
                                 + " WITH ("
                                 + "'"
+                                + HASH_BUCKET_NUM.key()
+                                + "'= '3',"
+                                + "'"
                                 + LAKESOUL_TABLE_PATH.key()
                                 + "'='" +
                                 getTempDirUri("/test_table")

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
@@ -53,7 +53,7 @@ public class LakeSoulSinkFailTest extends AbstractTestBase {
     public static Map<String, Tuple3<ResolvedSchema, String, MockTableSource.StopBehavior>> parameters;
     static String dropSourceSql = "drop table if exists test_source";
     static String createSourceSqlFormat = "create table if not exists test_source %s " +
-            "with ('connector'='lakesoul', 'path'='/', 'discoveryinterval'='1000')";
+            "with ('connector'='lakesoul', 'path'='/', 'hashBucketNum'='2', " + "'discoveryinterval'='1000'" + ")";
     static String dropSinkSql = "drop table if exists test_sink";
     static String createSinkSqlFormat = "create table if not exists test_sink %s %s" +
             "with ('connector'='lakesoul', 'path'='%s', 'hashBucketNum'='%d')";