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 2790b35121 [flink] NoopStoreSinkWriteState should do nothing instead 
of throwing UnsupportedOperationException (#5458)
2790b35121 is described below

commit 2790b3512179c34b7ecb8dc6e65fda32e4484d16
Author: tsreaper <[email protected]>
AuthorDate: Sun Apr 13 15:32:14 2025 +0800

    [flink] NoopStoreSinkWriteState should do nothing instead of throwing 
UnsupportedOperationException (#5458)
---
 .../java/org/apache/paimon/flink/sink/NoopStoreSinkWriteState.java  | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/NoopStoreSinkWriteState.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/NoopStoreSinkWriteState.java
index f975bce6ea..f1974da321 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/NoopStoreSinkWriteState.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/NoopStoreSinkWriteState.java
@@ -41,13 +41,11 @@ public class NoopStoreSinkWriteState implements 
StoreSinkWriteState {
 
     @Override
     public @Nullable List<StateValue> get(String tableName, String key) {
-        throw new UnsupportedOperationException();
+        return null;
     }
 
     @Override
-    public void put(String tableName, String key, List<StateValue> 
stateValues) {
-        throw new UnsupportedOperationException();
-    }
+    public void put(String tableName, String key, List<StateValue> 
stateValues) {}
 
     @Override
     public void snapshotState() throws Exception {}

Reply via email to