[hotfix] Use FlinkEnv in tests for ForStStateBackend

Zakelly · Dec 3, 2024 · e0c7582 · e0c7582
1 parent b66c90c
commit e0c7582
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/.../state/forst/ForStStateBackendTestV2.java → .../state/forst/ForStStateBackendV2Test.java b/.../state/forst/ForStStateBackendTestV2.java → .../state/forst/ForStStateBackendV2Test.java
@@ -43,7 +43,7 @@
 
 /** 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 @@ protected ConfigurableStateBackend getStateBackend() throws Exception {
         if (hasRemoteDir) {
             config.set(REMOTE_DIRECTORY, tempFolderForForstRemote.toString());
         }
-        backend.configure(config, Thread.currentThread().getContextClassLoader());
-        return new ForStStateBackend();
+        return backend.configure(config, Thread.currentThread().getContextClassLoader());
     }
 }