Согласно документации Apache Flink, есть параметр failOnCheckpointingErrors (в настоящее время не рекомендуется, но все еще поддерживается), если это истинное задание, должно завершиться неудачей, если оно не может создать контрольную точку (тайм-аут или исключение). Но на самом деле этого не происходит.
Может ли кто-нибудь указать мне, где я ошибаюсь в своих предположениях?