jackie created FLINK-25219:
------------------------------
Summary: 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
Reporter: jackie
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)
