Skip to content

Commit f5d3912

Browse files
committed
[flink] Set forceStartFlinkJob default to true for CompactAction
1 parent c4c0d6a commit f5d3912

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,7 @@ public CompactAction(
104104
Map<String, String> catalogConfig,
105105
Map<String, String> tableConf) {
106106
super(database, tableName, catalogConfig);
107+
this.forceStartFlinkJob = true;
107108
if (!(table instanceof FileStoreTable)) {
108109
throw new UnsupportedOperationException(
109110
String.format(
@@ -245,7 +246,7 @@ protected boolean buildForIncrementalClustering(
245246
table.coreOptions().legacyPartitionName());
246247

247248
long perSubtaskDataSize = table.coreOptions().clusteringPerTaskDataSize().getBytes();
248-
LOGGER.info("{} is {} bytes.", CLUSTERING_PER_TASK_DATA_SIZE, perSubtaskDataSize);
249+
LOGGER.info("{} is {} bytes.", CLUSTERING_PER_TASK_DATA_SIZE.key(), perSubtaskDataSize);
249250

250251
// 1. pick cluster files for each partition
251252
Map<BinaryRow, CompactUnit> compactUnits =

0 commit comments

Comments
 (0)