[
https://issues.apache.org/jira/browse/FLINK-25219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-25219:
----------------------------------
Component/s: Runtime / Configuration
> load configuration from flink-conf.yaml, some of my parameters were modified
> ----------------------------------------------------------------------------
>
> Key: FLINK-25219
> URL: https://issues.apache.org/jira/browse/FLINK-25219
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Configuration
> Reporter: jackie
> Priority: Critical
>
> Flink uses the following method to parse flink-conf.yaml.
> When there are # characters in my parameters, they will be modified.
> for example:
> flink-conf.yaml : s3.secret-key=abc#123
> At the end i will get ‘ s3.secret-key=abc’
> Why not use a better way to process flink-conf.yaml? like snakeyaml
> {code:java}
> String[] comments = line.split("#", 2);
> String conf = comments[0].trim();
> // 2. get key and value
> if (conf.length() > 0) {
> String[] kv = conf.split(": ", 2); {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
