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)
