search

apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://streampark.apache.org/
Apache License 2.0
3.91k stars 1.01k forks source link

[Bug] If the first start of a task fails, even if the task restart successfully, the application Run Status is incorrect #2536

Closed jasonzhuV closed 1 year ago

jasonzhuV commented 1 year ago

Search before asking

Java Version

1.8

Scala Version

2.12.x

StreamPark Version

release-2.0.0

Flink Version

1.14.5

deploy mode

yarn-application

What happened

  1. I create a application in "Custom Code" Mode in Steampark and set the Fault Restart Size as 3.
  2. I click "Start Application" after "Launch Application".
  3. Observe Option Logs，the application strat success, then jump to Flink Web UI, finally the job failed and jm is shutdown.
  4. Streampark restart application according to Fault Restart Size.
  5. Observe Option Logs angin, a new start log appears, jump to Flink Web UI, finally the job run successfully.
  6. Check the "Run Status" of application in streampark, it's "FAILED", but the FlinkJob is running in yarn.

Error Exception

No response

Screenshots

image image image image

Are you willing to submit PR?

Code of Conduct

wolfboys commented 1 year ago

hi: Thanks for your contribution, can you tell me why we need to add this enum value ?

jasonzhuV commented 1 year ago

In release-2.0.0, when getLaunchState was called, it will return LaunchState enum, the return might be null. I didn't notice the problem has been fixed in dev, Sorry to interrupt.

jasonzhuV commented 1 year ago

I will switch to the dev branch to confirm this issue later.

wolfboys commented 1 year ago

fixed, see this pr