(flink) 02/02: [FLINK-38137][state] Disable testMapStateWithNullValue for change log state backend temporarily

[fanrui]

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

fanrui pushed a commit to branch release-2.1
in repository https://gitbox.apache.org/repos/asf/flink.git

commit d2a88f6b0e87a637fd0759c7205e93af2f4d1a6f
Author: Rui Fan <1996fan...@gmail.com>
AuthorDate: Thu Jul 24 21:50:30 2025 +0200

    [FLINK-38137][state] Disable testMapStateWithNullValue for change log state 
backend temporarily
---
 .../ChangelogDelegateEmbeddedRocksDBStateBackendTest.java        | 8 ++++++++
 .../flink/state/changelog/ChangelogDelegateHashMapTest.java      | 9 +++++++++
 2 files changed, 17 insertions(+)

diff --git 
a/flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateEmbeddedRocksDBStateBackendTest.java
 
b/flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateEmbeddedRocksDBStateBackendTest.java
index 91ce7ae6b06..168ca6e1052 100644
--- 
a/flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateEmbeddedRocksDBStateBackendTest.java
+++ 
b/flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateEmbeddedRocksDBStateBackendTest.java
@@ -128,4 +128,12 @@ public class 
ChangelogDelegateEmbeddedRocksDBStateBackendTest
     protected boolean checkMetrics() {
         return false;
     }
+
+    // Follow https://issues.apache.org/jira/browse/FLINK-38144
+    @Override
+    @TestTemplate
+    @Disabled("Currently, ChangelogStateBackend does not support null values 
for map state")
+    public void testMapStateWithNullValue() throws Exception {
+        super.testMapStateWithNullValue();
+    }
 }
diff --git 
a/flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateHashMapTest.java
 
b/flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateHashMapTest.java
index e4235ad171c..8dda3deccf6 100644
--- 
a/flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateHashMapTest.java
+++ 
b/flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateHashMapTest.java
@@ -32,6 +32,7 @@ import org.apache.flink.runtime.state.StateBackend;
 import org.apache.flink.runtime.state.TestTaskStateManager;
 import org.apache.flink.testutils.junit.utils.TempDirUtils;
 
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.TestTemplate;
 import org.junit.jupiter.api.io.TempDir;
 
@@ -110,4 +111,12 @@ public class ChangelogDelegateHashMapTest extends 
HashMapStateBackendTest {
         ChangelogStateBackendTestUtils.testMaterializedRestoreForPriorityQueue(
                 getStateBackend(), env, streamFactory);
     }
+
+    // Follow https://issues.apache.org/jira/browse/FLINK-38144
+    @Override
+    @TestTemplate
+    @Disabled("Currently, ChangelogStateBackend does not support null values 
for map state")
+    public void testMapStateWithNullValue() throws Exception {
+        super.testMapStateWithNullValue();
+    }
 }