Have you configured checkpointing in your job. If enabled, the job should revert back to the last stored checkpoint in case of a failure and process the failed record again.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
