(streampark) branch dev-2.1.7 updated: [BUG] get flink config file bug fixed. (#4289)

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev-2.1.7
in repository https://gitbox.apache.org/repos/asf/streampark.git


The following commit(s) were added to refs/heads/dev-2.1.7 by this push:
     new 81b8161be [BUG] get flink config file bug fixed. (#4289)
81b8161be is described below

commit 81b8161be29dde828febe10ff4b050dde5448c0b
Author: benjobs <benj...@apache.org>
AuthorDate: Wed Sep 17 11:24:05 2025 +0800

    [BUG] get flink config file bug fixed. (#4289)
    
    * [BUG] get flink-config bug fixed.
    
    * [Improve] flink-env config file bug fixed.
---
 .../org/apache/streampark/console/core/entity/FlinkEnv.java   | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java
index 2cb6cd858..b99e24ece 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java
@@ -23,7 +23,6 @@ import org.apache.streampark.common.util.PropertiesUtils;
 import org.apache.streampark.console.base.exception.ApiAlertException;
 import org.apache.streampark.console.base.exception.ApiDetailException;
 
-import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.StringUtils;
 
 import com.baomidou.mybatisplus.annotation.IdType;
@@ -35,7 +34,6 @@ import lombok.Setter;
 
 import java.io.File;
 import java.io.Serializable;
-import java.nio.charset.StandardCharsets;
 import java.util.Date;
 import java.util.Map;
 
@@ -76,14 +74,7 @@ public class FlinkEnv implements Serializable {
   public void doSetFlinkConf() throws ApiDetailException {
     Float version = getVersionNumber();
     File configFile = resolveConfigFile(version);
-
-    try {
-      String flinkConf = FileUtils.readFileToString(configFile, 
StandardCharsets.UTF_8);
-      this.flinkConf = DeflaterUtils.zipString(flinkConf);
-    } catch (Exception e) {
-      throw new ApiDetailException(
-          "Failed to read Flink configuration file: " + 
configFile.getAbsolutePath(), e);
-    }
+    this.flinkConf = configFile.getAbsolutePath();
   }
 
   private File resolveConfigFile(Float version) throws ApiAlertException {