Major Description
The purpose of the StreamCheckpointingITCase is to run a job, throw an exception to trigger a task failure, and test the recovery process. In the test, the line (270), which is throwing the exception to cause the task failure, is commented out.
