[hotfix] Use FlinkEnv in tests for ForStStateBackend

Zakelly · Dec 3, 2024 · 5f23a84 · 5f23a84
1 parent b66c90c
commit 5f23a84
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...tatebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateBackendTestV2.java b/...tatebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateBackendTestV2.java
@@ -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());
     }
 }