[jira] [Created] (FLINK-29084) Program argument containing # (pound sign) mistakenly truncated in Kubernetes mode

["Weike Dong (Jira)" <ji...@apache.org>]

Weike Dong created FLINK-29084:
----------------------------------

             Summary: Program argument containing # (pound sign) mistakenly truncated in Kubernetes mode
                 Key: FLINK-29084
                 URL: https://issues.apache.org/jira/browse/FLINK-29084
             Project: Flink
          Issue Type: Bug
          Components: Deployment / Kubernetes
    Affects Versions: 1.15.1, 1.14.5, 1.13.6
         Environment: Flink 1.13.6

Native Kubernetes (Application Mode)
            Reporter: Weike Dong


We have found that when submitting jobs in native-Kubernetes mode, the main arguments of the Flink program would be truncated if it contains a # character.

For example, if we pass 'ab#cd' as the argument for Flink programs, Flink actually gets only 'ab' from the variable `$internal.application.program-args` at runtime.

After searching into the code, we found the reason might be that when `org.apache.flink.kubernetes.kubeclient.decorators.FlinkConfMountDecorator#buildAccompanyingKubernetesResources` transform Flink config data `Map` into `ConfigMap`, fabric8 Kubernetes client converts it to YAML internally, without any escaping procedures. Afterwards, when there is a # character in the YAML line, the decoder treats it as the start of a comment, thus the substring after the # character is ignored erroneously.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)