Skip to content

Commit 81b8161

Browse files
authored
[BUG] get flink config file bug fixed. (#4289)
* [BUG] get flink-config bug fixed. * [Improve] flink-env config file bug fixed.
1 parent 7548fdd commit 81b8161

File tree

1 file changed

+1
-10
lines changed
  • streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity

1 file changed

+1
-10
lines changed

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkEnv.java

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import org.apache.streampark.console.base.exception.ApiAlertException;
2424
import org.apache.streampark.console.base.exception.ApiDetailException;
2525

26-
import org.apache.commons.io.FileUtils;
2726
import org.apache.commons.lang3.StringUtils;
2827

2928
import com.baomidou.mybatisplus.annotation.IdType;
@@ -35,7 +34,6 @@
3534

3635
import java.io.File;
3736
import java.io.Serializable;
38-
import java.nio.charset.StandardCharsets;
3937
import java.util.Date;
4038
import java.util.Map;
4139

@@ -76,14 +74,7 @@ public class FlinkEnv implements Serializable {
7674
public void doSetFlinkConf() throws ApiDetailException {
7775
Float version = getVersionNumber();
7876
File configFile = resolveConfigFile(version);
79-
80-
try {
81-
String flinkConf = FileUtils.readFileToString(configFile, StandardCharsets.UTF_8);
82-
this.flinkConf = DeflaterUtils.zipString(flinkConf);
83-
} catch (Exception e) {
84-
throw new ApiDetailException(
85-
"Failed to read Flink configuration file: " + configFile.getAbsolutePath(), e);
86-
}
77+
this.flinkConf = configFile.getAbsolutePath();
8778
}
8879

8980
private File resolveConfigFile(Float version) throws ApiAlertException {

0 commit comments

Comments
 (0)