(paimon) branch master updated: [flink] Rename lastInsertOnly to insertOnly in StoreSinkWriteImpl

[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 9101a9eca [flink] Rename lastInsertOnly to insertOnly in 
StoreSinkWriteImpl
9101a9eca is described below

commit 9101a9eca35e6f88d356f8e9431ff54e627a8c93
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Thu Oct 10 15:35:57 2024 +0800

    [flink] Rename lastInsertOnly to insertOnly in StoreSinkWriteImpl
---
 .../java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java
index 709c2be63..ef8042820 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java
@@ -65,7 +65,7 @@ public class StoreSinkWriteImpl implements StoreSinkWrite {
 
     @Nullable private final MetricGroup metricGroup;
 
-    @Nullable private Boolean lastInsertOnly;
+    @Nullable private Boolean insertOnly;
 
     public StoreSinkWriteImpl(
             FileStoreTable table,
@@ -166,8 +166,8 @@ public class StoreSinkWriteImpl implements StoreSinkWrite {
                                     table.coreOptions().pageSize()));
         }
 
-        if (lastInsertOnly != null) {
-            tableWrite.withInsertOnly(lastInsertOnly);
+        if (insertOnly != null) {
+            tableWrite.withInsertOnly(insertOnly);
         }
 
         return tableWrite;
@@ -179,7 +179,7 @@ public class StoreSinkWriteImpl implements StoreSinkWrite {
 
     @Override
     public void withInsertOnly(boolean insertOnly) {
-        this.lastInsertOnly = insertOnly;
+        this.insertOnly = insertOnly;
         write.withInsertOnly(insertOnly);
     }