Hi, CheckpointableInputFormat is only relevant if you plan to use the InputFormat in a MonitoringFileSource, i.e., in a streaming application. If you plan to use it in a DataSet (batch) program, InputFormat is fine.
Btw. the latest release Flink 1.9.0 has major improvements for the recovery of batch jobs. Best, Fabian Am Do., 5. Sept. 2019 um 19:01 Uhr schrieb Lu Niu <qqib...@gmail.com>: > Hi, Team > > I am implementing a custom InputFormat. Shall I > implement CheckpointableInputFormat interface? If I don't, does that mean > the whole job has to restart given only one task fails? I ask because I > found all InputFormat implements CheckpointableInputFormat, which makes me > confused. Thank you! > > Best > Lu >
