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 b99e24ece2..2cb6cd8585 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,6 +23,7 @@ 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; @@ -34,6 +35,7 @@ import java.io.File; import java.io.Serializable; +import java.nio.charset.StandardCharsets; import java.util.Date; import java.util.Map; @@ -74,7 +76,14 @@ public class FlinkEnv implements Serializable { public void doSetFlinkConf() throws ApiDetailException { Float version = getVersionNumber(); File configFile = resolveConfigFile(version); - this.flinkConf = configFile.getAbsolutePath(); + + 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); + } } private File resolveConfigFile(Float version) throws ApiAlertException {