[flink] fix

apache · Nov 26, 2024 · 9c959d0 · 9c959d0
1 parent d7e2290
commit 9c959d0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...nk-common/src/main/java/org/apache/paimon/flink/sink/MultiTablesStoreCompactOperator.java b/...nk-common/src/main/java/org/apache/paimon/flink/sink/MultiTablesStoreCompactOperator.java
@@ -162,13 +162,13 @@ public void processElement(StreamRecord<RowData> element) throws Exception {
 
         if (write.streamingMode()) {
             write.notifyNewFiles(snapshotId, partition, bucket, files);
+            // The full compact is not supported in streaming mode.
             write.compact(partition, bucket, false);
         } else {
             Preconditions.checkArgument(
                     files.isEmpty(),
                     "Batch compact job does not concern what files are compacted. "
                             + "They only need to know what buckets are compacted.");
-            // `minor` compact strategy is supported in batch mode.
             write.compact(partition, bucket, fullCompaction);
         }
     }

diff --git a/...n-flink-common/src/test/java/org/apache/paimon/flink/action/MinorCompactActionITCase.java b/...n-flink-common/src/test/java/org/apache/paimon/flink/action/MinorCompactActionITCase.java
@@ -172,6 +172,6 @@ public void testStreamingFullCompactStrategy() throws Exception {
                 streamExecutionEnvironmentBuilder().streamingMode().build();
         Assertions.assertThatThrownBy(() -> action.withStreamExecutionEnvironment(env).build())
                 .hasMessage(
-                        "full compact strategy is only supported in batch mode. Please add -Dexecution.runtime-mode=BATCH.");
+                        "The full compact strategy is only supported in batch mode. Please add -Dexecution.runtime-mode=BATCH.");
     }
 }