public boolean isCheckpointingEnabled ( ) { if ( snapshotSettings == null ) { return false ; } long checkpointInterval = snapshotSettings . getCheckpointCoordinatorConfiguration ( ) . getCheckpointInterval ( ) ; return checkpointInterval > 0 && checkpointInterval < Long . MAX_VALUE ; }
Checks if the checkpointing was enabled for this job graph