[
https://issues.apache.org/jira/browse/FLINK-37266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-37266:
-------------------------------
Assignee: Dian Fu
> 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
> Assignee: Dian Fu
> Priority: Major
> Attachments: screenshot-1.png
>
>
> 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
> !screenshot-1.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
