You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "jackie (Jira)" <ji...@apache.org> on 2021/12/08 10:19:00 UTC

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

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)