incubator-streampark
incubator-streampark copied to clipboard
[Bug] Yarn mode The specified queue is invalid
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
The YARN mode specifies that the queue is invalid or the default queue is used. It is normal to test the specified queue on the command line
StreamPark Version
1.2.3
Java Version
1.8.0_212
Flink Version
1.15.2
Scala Version of Flink
1.12
Error Exception
Tasks run in the default queue
Screenshots
No response
Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct
Hi @yileii , thanks for you feeback.
This was indeed a bug in the 1.2.3 version , but we've fixed it in the 1.2.4-snapshot version, and you can use the -Dyarn.application.queue=queue
parameter to make the configuration work in previous versions.