Dian Fu created FLINK-37266:
-------------------------------

             Summary: Python CLI arguments doesn't work in session mode
                 Key: FLINK-37266
                 URL: https://issues.apache.org/jira/browse/FLINK-37266
             Project: Flink
          Issue Type: Bug
          Components: API / Python
            Reporter: Dian Fu


ran the python with flinksessionjob I got the below error
{code}
ERROR org.apache.flink.client.python.PythonDriver                  [] - Could 
not parse command line arguments [-pyclientexec, /usr/local/bin/python3, -py, 
/opt/flink/python_demo.py].
{code}

the flinksessionjob is:
{code}
apiVersion: flink.apache.org/v1beta1
kind: FlinkSessionJob
metadata:
  name: basic-session-job-example
spec:
  deploymentName: flink
  job:
    jarURI: 
https://repo1.maven.org/maven2/org/apache/flink/flink-examples-streaming_2.12/1.16.1/flink-examples-streaming_2.12-1.16.1-TopSpeedWindowing.jar
 
    entryClass: "org.apache.flink.client.python.PythonDriver"
    args: ["-pyclientexec", "/usr/local/bin/python3", "-py", 
"/opt/flink/python_demo.py"]
    parallelism: 1
    upgradeMode: stateless
{code}

See more details in the slack channel: 
https://apache-flink.slack.com/archives/C065944F9M2/p1736921789695069



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

Reply via email to