-
Notifications
You must be signed in to change notification settings - Fork 5k
[Bug][plugin] Flink run command error when submitting Python job #10039
Copy link
Copy link
Closed
Labels
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
When the program type of the Flink run program is Python, the Flink run command is wrong and cannot be successful
Steps to reproduce the problem
Flink run command missing "-py" when program type is Python.
The flink task configuration is as follows:

Flink run command error when program type is Python:
The correct command of flink run runs as follows:

Brief Changelog
Add logical judgment when Flink programming language is Python to FlinkTask.class.
Add command parameters when Flink programming language is Python to FlinkConstants.class
Anything else
No response
Version
dev
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct
Reactions are currently unavailable
