This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit b660b06cb70ed9ccd72b1088d4bd174c11673b59 Author: Piotr Nowojski <[email protected]> AuthorDate: Wed Jan 10 13:35:13 2024 +0100 [hotfix][test] Fix propagation of useManagedMemory flag --- .../main/java/org/apache/flink/streaming/tests/StubStateBackend.java | 5 +++++ .../java/org/apache/flink/runtime/state/StateBackendTestUtils.java | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/StubStateBackend.java b/flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/StubStateBackend.java index 5f1079488e9..57edcb17e45 100644 --- a/flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/StubStateBackend.java +++ b/flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/StubStateBackend.java @@ -85,6 +85,11 @@ final class StubStateBackend implements StateBackend { cancelStreamRegistry); } + @Override + public boolean useManagedMemory() { + return backend.useManagedMemory(); + } + @Override public OperatorStateBackend createOperatorStateBackend( Environment env, diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestUtils.java b/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestUtils.java index acd96d24aae..969d607d09b 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestUtils.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestUtils.java @@ -70,6 +70,11 @@ public class StateBackendTestUtils { this.snapshotResultFunction = snapshotResultFunction; } + @Override + public boolean useManagedMemory() { + return delegatedStataBackend.useManagedMemory(); + } + @Override public <K> AbstractKeyedStateBackend<K> createKeyedStateBackend( Environment env,
