From 5f23a84f16bb24909b6f5a5c0f5a48c6bf931e45 Mon Sep 17 00:00:00 2001 From: Zakelly Date: Tue, 3 Dec 2024 22:03:20 +0800 Subject: [PATCH] [hotfix] Use `FlinkEnv` in tests for ForStStateBackend --- .../org/apache/flink/state/forst/ForStStateBackendTestV2.java | 3 +-- 1 file changed, 1 insertion(+), 2 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/ForStStateBackendTestV2.java index 413f81532ff89b..c01e89036190ee 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/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()); } }