Skip to content

[Bug][plugin] Flink run command error when submitting Python job #10039

@Dannila

Description

@Dannila

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:
ef90c731272b9d3f9c066080e3d1fbf407d35f7f63d3cd6b220278227e05c3b1QzpcVXNlcnNcQWRtaW5pc3RyYXRvclxBcHBEYXRhXFJvYW1pbmdcRGluZ1RhbGtcMjQ5MjQ4MDk3Ml92MlxJbWFnZUZpbGVzXDE2NTI2NjQ2ODIyODNfQkJEQTU2ODEtQURDMi00ZDMyLUJBNzItQTBBNzM0MjM5OERFLnBuZw==

Flink run command error when program type is Python:

e96c5ab4ea380140aee19967eacb822adfca15c3743e60ccef8fa12624c695fbQzpcVXNlcnNcQWRtaW5pc3RyYXRvclxBcHBEYXRhXFJvYW1pbmdcRGluZ1RhbGtcMjQ5MjQ4MDk3Ml92MlxJbWFnZUZpbGVzXDE2NTI2NzA2ODU2MzlfODI1NjcwN0YtODRDQy00OWY2LUExQUUtMzExQjFDOERFNDk1LnBuZw==

The correct command of flink run runs as follows:
b58b3af3455089faeb61314d5c2fa80b4507ae646e0ebc4b05b075a4d02f9b65QzpcVXNlcnNcQWRtaW5pc3RyYXRvclxBcHBEYXRhXFJvYW1pbmdcRGluZ1RhbGtcMjQ5MjQ4MDk3Ml92MlxJbWFnZUZpbGVzXDE2NTI2NjQ3MzY0NjBfMTc2NDM1NTEtMkQ1Qy00ZDA4LUFCNEEtMTdFMjFDMEJFOTAyLnBuZw==

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

Metadata

Metadata

Assignees

Labels

backendbugSomething isn't working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions