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 {}