You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Noticed this issue with some streaming clusters using mode:Application and restartPolicy: FromSavepointOnFailure
To allow for a job restart(recreate), job status is set to Restarting by the operator.
In cases when the job's backoff limit is reached the operator can get stuck in this step: 2. Update cluster status because the job state keeps changing in this loop: Restarting -> Deploying -> Failed -> Restarting
So, the reconciliation of the FlinkCluster never reaches the next step: 3. Compute the desired state
It seems like a race condition between the Job and this operator's reconcilers.
Potential fix could be to not have the operator not edit status.job.state manually and only read the actual job state?
The text was updated successfully, but these errors were encountered:
Noticed this issue with some streaming clusters using
mode:Application
andrestartPolicy: FromSavepointOnFailure
To allow for a job restart(recreate), job status is set to
Restarting
by the operator.In cases when the job's backoff limit is reached the operator can get stuck in this step:
2. Update cluster status
because the job state keeps changing in this loop:Restarting
->Deploying
->Failed
->Restarting
So, the reconciliation of the FlinkCluster never reaches the next step:
3. Compute the desired state
It seems like a race condition between the Job and this operator's reconcilers.
Potential fix could be to not have the operator not edit
status.job.state
manually and only read the actual job state?The text was updated successfully, but these errors were encountered: