This is an automated email from the ASF dual-hosted git repository. benjobs pushed a commit to branch flink-config in repository https://gitbox.apache.org/repos/asf/streampark.git
commit b51e970cab3a17ca7ab5b25531444c6fe8df086b Author: benjobs <[email protected]> AuthorDate: Wed Sep 17 11:21:34 2025 +0800 [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 {
