(paimon) branch master updated: [core] Ensure triggerCompaction in RecordWriter.isCompacting (#4574)

[lzljs3620320]

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 0057538b8f [core] Ensure triggerCompaction in 
RecordWriter.isCompacting (#4574)
0057538b8f is described below

commit 0057538b8fc626cf4698274ccfbd71eb9d66b621
Author: Jingsong Lee <jingsongl...@gmail.com>
AuthorDate: Fri Nov 22 19:05:39 2024 +0800

    [core] Ensure triggerCompaction in RecordWriter.isCompacting (#4574)
---
 paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java | 1 +
 .../src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java       | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java 
b/paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java
index 47502aa707..a3087e3628 100644
--- a/paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java
+++ b/paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyWriter.java
@@ -211,6 +211,7 @@ public class AppendOnlyWriter implements BatchRecordWriter, 
MemoryOwner {
 
     @Override
     public boolean isCompacting() {
+        compactManager.triggerCompaction(false);
         return compactManager.isCompacting();
     }
 
diff --git 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java
index b73be6941e..f2a964bae1 100644
--- a/paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java
+++ b/paimon-core/src/main/java/org/apache/paimon/mergetree/MergeTreeWriter.java
@@ -279,6 +279,7 @@ public class MergeTreeWriter implements 
RecordWriter<KeyValue>, MemoryOwner {
 
     @Override
     public boolean isCompacting() {
+        compactManager.triggerCompaction(false);
         return compactManager.isCompacting();
     }