Hi @tillrohrmann , Currently it is applied to the sub task instance (TM) instead of the checkpoint coordinator (JM) as a complement to the setFailOnCheckpointingErrors method, since setFailOnCheckpointingErrors only provides the user with yes or no choices.
But it sounds reasonable to apply the count on the Job globally. [ Full content available at: https://github.com/apache/flink/pull/6567 ] This message was relayed via gitbox.apache.org for [email protected]
