You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fa...@apache.org on 2025/07/28 09:46:58 UTC
(flink) 02/02: [FLINK-38137][state] Disable testMapStateWithNullValue for change log state backend temporarily
This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 70b673406299fa518300a8ef3bdfcd7899358f63
Author: Rui Fan <19...@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();
+ }
}