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 index e44aa4c63d89..dc7bf397e4a9 100644 --- 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 result = batchSql("SELECT * FROM T1"); diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java index 0bedbfd024d1..76ee8309e8b5 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java +++ b/paimon-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/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java index e4c90695b1b2..b8dfd8f6a86e 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PreAggregationITCase.java @@ -1172,7 +1172,7 @@ protected List 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'" + ");"); }