This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 966aa74c54 [flink] Set forceStartFlinkJob default to true for
CompactAction (#6631)
966aa74c54 is described below
commit 966aa74c54573d42fee8730140271d4a4968bddb
Author: LsomeYeah <[email protected]>
AuthorDate: Wed Nov 19 16:21:20 2025 +0800
[flink] Set forceStartFlinkJob default to true for CompactAction (#6631)
---
.../src/main/java/org/apache/paimon/flink/action/CompactAction.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java
index 3e3018a2a2..e77574c7e1 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java
@@ -104,6 +104,7 @@ public class CompactAction extends TableActionBase {
Map<String, String> catalogConfig,
Map<String, String> tableConf) {
super(database, tableName, catalogConfig);
+ this.forceStartFlinkJob = true;
if (!(table instanceof FileStoreTable)) {
throw new UnsupportedOperationException(
String.format(
@@ -245,7 +246,7 @@ public class CompactAction extends TableActionBase {
table.coreOptions().legacyPartitionName());
long perSubtaskDataSize =
table.coreOptions().clusteringPerTaskDataSize().getBytes();
- LOGGER.info("{} is {} bytes.", CLUSTERING_PER_TASK_DATA_SIZE,
perSubtaskDataSize);
+ LOGGER.info("{} is {} bytes.", CLUSTERING_PER_TASK_DATA_SIZE.key(),
perSubtaskDataSize);
// 1. pick cluster files for each partition
Map<BinaryRow, CompactUnit> compactUnits =
