Skip to content

Commit 45cf955

Browse files
authored
Merge pull request #6287 from liwang0513/lwang/fix_flink_interpreter
update Flink interpreter to check error when job state is not published
2 parents 2513867 + 6d5cf43 commit 45cf955

File tree

1 file changed

+1
-1
lines changed
  • pkg/resourceinterpreter/default/thirdparty/resourcecustomizations/flink.apache.org/v1beta1/FlinkDeployment

1 file changed

+1
-1
lines changed

pkg/resourceinterpreter/default/thirdparty/resourcecustomizations/flink.apache.org/v1beta1/FlinkDeployment/customizations.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ spec:
3030
return observedObj.status.error ~= nil or observedObj.status.jobManagerDeploymentStatus == 'ERROR'
3131
end
3232
end
33-
return false
33+
return observedObj.status.error ~= nil
3434
end
3535
replicaResource:
3636
luaScript: >

0 commit comments

Comments
 (0)