You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "tanjialiang (Jira)" <ji...@apache.org> on 2022/12/28 09:13:00 UTC

[jira] [Created] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

tanjialiang created FLINK-30520:
-----------------------------------

             Summary: Arguments contains with '#' will error split in loadYAMLResource
                 Key: FLINK-30520
                 URL: https://issues.apache.org/jira/browse/FLINK-30520
             Project: Flink
          Issue Type: Bug
          Components: API / Core
    Affects Versions: 1.15.3, 1.14.6, 1.16.0
            Reporter: tanjialiang


When i submit a flink jar job in Kubernetes Application mode which main args contains '#', it will be error split by org.apache.flink.configuration.GlobalConfiguration#loadYAMLResource

 

such as i using flink-kubernetes-operator to submit a job in kubernetes application mode

 
{code:java}
apiVersion: flink.apache.org/v1beta1
kind: FlinkDeployment
metadata:
  name: word-count
spec:
  image: apache/flink:1.16.0-scala_2.12-java8
  flinkVersion: v1_16
  flinkConfiguration:
    taskmanager.numberOfTaskSlots: "1"
  jobManager:
    resource:
      memory: "2048m"
      cpu: 1
  taskManager:
    resource:
      memory: "2048m"
      cpu: 1
  serviceAccount: flink
  job:
    jarURI: local:///opt/flink/examples/streaming/WordCount.jar
    args:
      - --output
      - /tmp/1#.txt
    parallelism: 2
    upgradeMode: stateless
{code}
 

 

It will be error split when loading the flink-conf.yaml

!image-2022-12-28-16-30-30-645.png!

 

And i enter to the jobmanager's pod to saw the flink-conf.yaml's program-args is right

!image-2022-12-28-16-34-25-819.png!

 

Maybe we should have a more strict validate for yaml comment?

 



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