@Override
	public CheckpointStorage createCheckpointStorage(JobID jobId) throws IOException {
		checkNotNull(jobId, "jobId");
		return new FsCheckpointStorage(getCheckpointPath(), getSavepointPath(), jobId, getMinFileSizeThreshold());
	}
@ Override public CheckpointStorage createCheckpointStorage ( JobID jobId ) throws IOException { checkNotNull ( jobId , "jobId" ) ; return new FsCheckpointStorage ( getCheckpointPath ( ) , getSavepointPath ( ) , jobId , getMinFileSizeThreshold ( ) ) ; }
------------------------------------------------------------------------