Skip to content

Commit 8f7625e

Browse files
authored
[hotfix] Fix dedicated compaction (#5146)
1 parent 3ae1414 commit 8f7625e

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/CompactorSourceBuilder.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -86,18 +86,18 @@ public CompactorSourceBuilder withPartitionIdleTime(@Nullable Duration partition
8686
}
8787

8888
private Source<RowData, ?, ?> buildSource(CompactBucketsTable compactBucketsTable) {
89+
compactBucketsTable =
90+
compactBucketsTable.copy(
91+
isContinuous ? streamingCompactOptions() : batchCompactOptions());
8992
ReadBuilder readBuilder =
9093
compactBucketsTable.newReadBuilder().withFilter(partitionPredicate);
91-
if (compactBucketsTable.coreOptions().manifestDeleteFileDropStats()) {
94+
if (CoreOptions.fromMap(table.options()).manifestDeleteFileDropStats()) {
9295
readBuilder = readBuilder.dropStats();
9396
}
9497
if (isContinuous) {
95-
compactBucketsTable = compactBucketsTable.copy(streamingCompactOptions());
9698
return new ContinuousFileStoreSource(readBuilder, compactBucketsTable.options(), null);
9799
} else {
98-
compactBucketsTable = compactBucketsTable.copy(batchCompactOptions());
99100
Options options = compactBucketsTable.coreOptions().toConfiguration();
100-
101101
return new StaticFileStoreSource(
102102
readBuilder,
103103
null,

0 commit comments

Comments
 (0)