This is an automated email from the ASF dual-hosted git repository. zakelly pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7d95fe8ba92841cf535f079d1d85c95fca1c1028 Author: Zakelly <[email protected]> AuthorDate: Tue Dec 3 22:03:20 2024 +0800 [hotfix] Use `FlinkEnv` in tests for ForStStateBackend --- .../{ForStStateBackendTestV2.java => ForStStateBackendV2Test.java} | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateBackendTestV2.java b/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateBackendV2Test.java similarity index 95% rename from flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateBackendTestV2.java rename to flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateBackendV2Test.java index 413f81532ff..ff77675d05b 100644 --- a/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateBackendTestV2.java +++ b/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateBackendV2Test.java @@ -43,7 +43,7 @@ import static org.apache.flink.state.forst.ForStOptions.REMOTE_DIRECTORY; /** Tests for the async keyed state backend part of {@link ForStStateBackend}. */ @ExtendWith(ParameterizedTestExtension.class) -class ForStStateBackendTestV2 extends StateBackendTestV2Base<ForStStateBackend> { +class ForStStateBackendV2Test extends StateBackendTestV2Base<ForStStateBackend> { @TempDir private static java.nio.file.Path tempFolder; @TempDir private static java.nio.file.Path tempFolderForForStLocal; @@ -94,7 +94,6 @@ class ForStStateBackendTestV2 extends StateBackendTestV2Base<ForStStateBackend> if (hasRemoteDir) { config.set(REMOTE_DIRECTORY, tempFolderForForstRemote.toString()); } - backend.configure(config, Thread.currentThread().getContextClassLoader()); - return new ForStStateBackend(); + return backend.configure(config, Thread.currentThread().getContextClassLoader()); } }
