container/src/main/java/com/streamsets/datacollector/runner/PipeRunner.java
public boolean onRecordErrorStopPipeline() {
    for(Pipe pipe : pipes) {
      StageContext stageContext = pipe.getStage().getContext();
      if(stageContext.getOnErrorRecord() == OnRecordError.STOP_PIPELINE) {
        return true;
      }
    }

    return false;
  }
public boolean onRecordErrorStopPipeline() {
    for(Pipe pipe : pipes) {
      StageContext stageContext = pipe.getStage().getContext();
      if(stageContext.getOnErrorRecord() == OnRecordError.STOP_PIPELINE) {
        return true;
      }
    }

    return false;
  }
Return true if at least one stage is configured with STOP_PIPELINE for OnRecordError policy.