You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2024/10/10 07:36:10 UTC
(paimon) branch master updated: [flink] Rename lastInsertOnly to insertOnly in StoreSinkWriteImpl
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 <ji...@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);
}