Skip to content

Commit 6a5fa6d

Browse files
committed
[core] Fix in Data Evolution class
1 parent 141d032 commit 6a5fa6d

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@
3535

3636
import java.util.ArrayList;
3737
import java.util.Collections;
38-
import java.util.Comparator;
3938
import java.util.List;
4039
import java.util.Objects;
4140

@@ -50,7 +49,6 @@ public class AppendCompactTask {
5049

5150
public AppendCompactTask(BinaryRow partition, List<DataFileMeta> files) {
5251
Preconditions.checkArgument(files != null);
53-
files.sort(Comparator.comparingLong(DataFileMeta::minSequenceNumber));
5452
this.partition = partition;
5553
compactBefore = new ArrayList<>(files);
5654
compactAfter = new ArrayList<>();

paimon-core/src/main/java/org/apache/paimon/append/dataevolution/DataEvolutionCompactTask.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@
3838
import org.apache.paimon.utils.RecordWriter;
3939

4040
import java.util.Collections;
41+
import java.util.Comparator;
4142
import java.util.List;
4243
import java.util.Map;
4344
import java.util.Objects;
@@ -57,6 +58,7 @@ public DataEvolutionCompactTask(
5758
BinaryRow partition, List<DataFileMeta> files, boolean blobTask) {
5859
super(partition, files);
5960
this.blobTask = blobTask;
61+
this.compactBefore().sort(Comparator.comparingLong(DataFileMeta::minSequenceNumber));
6062
}
6163

6264
public boolean isBlobTask() {

0 commit comments

Comments
 (0)