container/src/main/java/com/streamsets/datacollector/execution/runner/common/ProductionPipelineRunner.java
public void stop() throws PipelineException {
    this.stop = true;
    if(batchesToCapture > 0) {
      cancelSnapshot(this.snapshotName);
      snapshotStore.deleteSnapshot(pipelineName, revision, snapshotName);
    }
  }
public void stop() throws PipelineException {
    this.stop = true;
    if(batchesToCapture > 0) {
      cancelSnapshot(this.snapshotName);
      snapshotStore.deleteSnapshot(pipelineName, revision, snapshotName);
    }
  }
public void stop ( ) throws PipelineException { this . stop = true ; if ( batchesToCapture > 0 ) { cancelSnapshot ( this . snapshotName ) ; snapshotStore . deleteSnapshot ( pipelineName , revision , snapshotName ) ; } }
Stops execution of the pipeline after the current batch completes
Stops execution of the pipeline after the current batch completes