[
https://issues.apache.org/jira/browse/FLINK-37266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-37266.
---------------------------
Fix Version/s: 2.2.0
1.20.4
2.1.2
2.0.2
Resolution: Fixed
Fixed in:
- master via 8f7f3e4e8af26546f9af3d624e23928eccd50392
- release-2.1 via f8193602de2ea20f819390a032c9278e7b7b23b9
- release-2.0 via f846e1da0af32cb6984f354c70c5e883b9ab09dc
- release-1.20 via 1352bed47b96eb9c796fbbcc49d2c3b74129b628
> 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
> Labels: pull-request-available
> Fix For: 2.2.0, 1.20.4, 2.1.2, 2.0.2
>
> 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)
