incubator-streampark icon indicating copy to clipboard operation
incubator-streampark copied to clipboard

[Bug] flink1.14,when start flink job , status always in starting

Open waywtdcc opened this issue 2 years ago • 3 comments

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

waywtdcc avatar Aug 05 '22 02:08 waywtdcc

I had the same problem on streamX 1.2.3 with flink 1.12

Shmilyqjj avatar Aug 18 '22 06:08 Shmilyqjj

StreamX 1.2.4 is not released, how this happen

msftgitsklsd avatar Aug 18 '22 09:08 msftgitsklsd

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.

Shmilyqjj avatar Sep 02 '22 03:09 Shmilyqjj

fixed

wolfboys avatar Mar 19 '23 04:03 wolfboys