incubator-streampark
incubator-streampark copied to clipboard
[Bug] flink1.14,when start flink job , status always in starting
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
flink1.14,when start flink job , status always in starting,but job has error. use yarn application mode.
StreamX Version
1.2.4
Java Version
1.8
Flink Version
1.14.5
Scala Version of Flink
2.11
Error Exception
flink1.14,when start flink job , status always in starting,but job has error.
use yarn application mode.
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
I had the same problem on streamX 1.2.3 with flink 1.12
StreamX 1.2.4 is not released, how this happen
I had the same problem on streamX 1.2.3 with flink 1.12
I had solved this problem.
When requesting yarn web proxy server, cookie:checked_<applicationId>=true is required to request app information in my yarn cluster,so this step can not get app information,and streamX will tracking app status with yarn rest api,but when it is requesting yarn rest api, streamX uses the wrong url(yarn.web-proxy.address), the correct url is activeRMIp:8088, so I modified related codes, then it worked well.
fixed