(flink) 01/02: [FLINK-20772][State] Make TtlValueState#update follow the description of interface about null values

[hangxiang]

This is an automated email from the ASF dual-hosted git repository.

hangxiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit ac1ed6b60a6358b8a87effc26e2e774c36ed0a37
Author: Zakelly <zakelly....@gmail.com>
AuthorDate: Fri Dec 15 12:36:38 2023 +0800

    [FLINK-20772][State] Make TtlValueState#update follow the description of 
interface about null values
---
 .../src/main/java/org/apache/flink/runtime/state/ttl/TtlValueState.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlValueState.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlValueState.java
index 1d68a45d864..344f0b5e949 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlValueState.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlValueState.java
@@ -48,7 +48,7 @@ class TtlValueState<K, N, T>
     @Override
     public void update(T value) throws IOException {
         accessCallback.run();
-        original.update(wrapWithTs(value));
+        original.update(value == null ? null : wrapWithTs(value));
     }
 
     @Nullable