[FLINK-25219] load configuration from flink-conf.yaml, some of my parameters were modified

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Runtime / Configuration
• Assignee: Unassigned
• Reporter: jackie
• Created: 08/Dec/21 10:18
• Updated: 13/Dec/21 10:36

Description

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

String[] comments = line.split("#", 2);
String conf = comments[0].trim();

// 2. get key and value
if (conf.length() > 0) {
    String[] kv = conf.split(": ", 2);