Skip to content

Commit b8ae77b

Browse files
committed
fix
1 parent acb2bb9 commit b8ae77b

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

paimon-core/src/main/java/org/apache/paimon/append/UnawareAppendTableCompactionCoordinator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -327,7 +327,7 @@ public void addFile(DataFileMeta file) {
327327
}
328328

329329
private boolean enoughContent() {
330-
return bin.size() > 1 && totalFileSize >= targetFileSize * 50;
330+
return bin.size() > 1 && totalFileSize >= targetFileSize * 2;
331331
}
332332

333333
private boolean enoughInputFiles() {

paimon-core/src/test/java/org/apache/paimon/append/UnawareAppendTableCompactionCoordinatorTest.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public class UnawareAppendTableCompactionCoordinatorTest {
6262
@Test
6363
public void testForCompactPlan() {
6464
List<DataFileMeta> files = generateNewFiles(200, 0);
65-
assertTasks(files, 1);
65+
assertTasks(files, 2);
6666
}
6767

6868
@Test
@@ -76,7 +76,7 @@ public void testMinSizeCompactTask() {
7676
List<DataFileMeta> files =
7777
generateNewFiles(
7878
100, appendOnlyFileStoreTable.coreOptions().targetFileSize(false) / 3 + 1);
79-
assertTasks(files, 1);
79+
assertTasks(files, 17);
8080
}
8181

8282
@Test
@@ -94,14 +94,14 @@ public void testCompactGroupSplit() {
9494
1000, appendOnlyFileStoreTable.coreOptions().targetFileSize(false) / 10);
9595
compactionCoordinator.notifyNewFiles(partition, files);
9696

97-
assertThat(compactionCoordinator.compactPlan().size()).isEqualTo(3);
97+
assertThat(compactionCoordinator.compactPlan().size()).isEqualTo(56);
9898
files.clear();
9999

100100
files =
101101
generateNewFiles(
102102
1050, appendOnlyFileStoreTable.coreOptions().targetFileSize(false) / 5);
103103
compactionCoordinator.notifyNewFiles(partition, files);
104-
assertThat(compactionCoordinator.compactPlan().size()).isEqualTo(5);
104+
assertThat(compactionCoordinator.compactPlan().size()).isEqualTo(105);
105105
}
106106

107107
@Test
@@ -110,7 +110,7 @@ public void testCompactGroupSplit2() {
110110
generateNewFiles(
111111
1089, appendOnlyFileStoreTable.coreOptions().targetFileSize(false) / 5);
112112
compactionCoordinator.notifyNewFiles(partition, files);
113-
assertThat(compactionCoordinator.compactPlan().size()).isEqualTo(5);
113+
assertThat(compactionCoordinator.compactPlan().size()).isEqualTo(109);
114114
}
115115

116116
@Test

0 commit comments

Comments
 (0)