fix

apache · Nov 11, 2024 · 2a6b4a9 · 2a6b4a9
1 parent 1f5b276
commit 2a6b4a9
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FirstRowITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/FirstRowITCase.java
@@ -95,7 +95,7 @@ public void testLocalMerge() {
         sql(
                 "CREATE TABLE IF NOT EXISTS T1 ("
                         + "a INT, b INT, c STRING, PRIMARY KEY (a, b) NOT ENFORCED)"
-                        + " PARTITIONED BY (b) WITH ('merge-engine'='first-row', 'local-merge-buffer-size' = '1m',"
+                        + " PARTITIONED BY (b) WITH ('merge-engine'='first-row', 'local-merge-buffer-size' = '5m',"
                         + " 'file.format'='avro', 'changelog-producer' = 'lookup');");
         batchSql("INSERT INTO T1 VALUES (1, 1, '1'), (1, 1, '2'), (2, 3, '3')");
         List<Row> result = batchSql("SELECT * FROM T1");

diff --git a/...-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java b/...-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java
@@ -351,7 +351,7 @@ public void testLocalMerge() {
                         + "d INT,"
                         + "PRIMARY KEY (k, d) NOT ENFORCED) PARTITIONED BY (d) "
                         + " WITH ('merge-engine'='partial-update', "
-                        + "'local-merge-buffer-size'='1m'"
+                        + "'local-merge-buffer-size'='5m'"
                         + ");");
 
         sql("INSERT INTO T1 VALUES (1, CAST(NULL AS INT), 1), (2, 1, 1), (1, 2, 1)");
@@ -588,7 +588,7 @@ public void testIgnoreDelete(boolean localMerge) throws Exception {
                         + " 'changelog-producer' = 'lookup'"
                         + ")");
         if (localMerge) {
-            sql("ALTER TABLE ignore_delete SET ('local-merge-buffer-size' = '256 kb')");
+            sql("ALTER TABLE ignore_delete SET ('local-merge-buffer-size' = '5m')");
         }
 
         sql("INSERT INTO ignore_delete VALUES (1, CAST (NULL AS STRING), 'apple')");

diff --git a/...flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java b/...flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java
@@ -1172,7 +1172,7 @@ protected List<String> ddl() {
                             + "PRIMARY KEY (k, d) NOT ENFORCED) PARTITIONED BY (d) "
                             + " WITH ('merge-engine'='aggregation', "
                             + "'fields.v.aggregate-function'='sum',"
-                            + "'local-merge-buffer-size'='1m'"
+                            + "'local-merge-buffer-size'='5m'"
                             + ");");
         }