cluster-bootstrap-api/src/main/java/com/streamsets/pipeline/SdcClusterOffsetHelper.java
public boolean isSDCCheckPointing()  {
    try {
      return fs.exists(checkPointFilePath) || fs.exists(backupCheckPointFilePath);
    } catch (IOException ex) {
      LOG.error("Error doing isSDCCheckPointing", ex);
      throw new RuntimeException(Utils.format("Error checking exists on hdfs path: {}. Reason: {}", checkPointFilePath.toString(), ex.toString()), ex);
    }
  }
public boolean isSDCCheckPointing()  {
    try {
      return fs.exists(checkPointFilePath) || fs.exists(backupCheckPointFilePath);
    } catch (IOException ex) {
      LOG.error("Error doing isSDCCheckPointing", ex);
      throw new RuntimeException(Utils.format("Error checking exists on hdfs path: {}. Reason: {}", checkPointFilePath.toString(), ex.toString()), ex);
    }
  }
public boolean isSDCCheckPointing ( ) { try { return fs . exists ( checkPointFilePath ) || fs . exists ( backupCheckPointFilePath ) ; } catch ( IOException ex ) { LOG . error ( "Error doing isSDCCheckPointing" , ex ) ; throw new RuntimeException ( Utils . format ( "Error checking exists on hdfs path: {}. Reason: {}" , checkPointFilePath . toString ( ) , ex . toString ( ) ) , ex ) ; } }
This tell us SDC is check pointing
This tell us SDC is check pointing