container/src/main/java/com/streamsets/datacollector/runner/RunnerPool.java
private void validateNotDestroyed() throws PipelineRuntimeException {
    if(destroyed.get()) {
      throw new PipelineRuntimeException(ContainerError.CONTAINER_0803, queue.size(), runtimeStats.getTotalRunners());
    }
  }
private void validateNotDestroyed() throws PipelineRuntimeException {
    if(destroyed.get()) {
      throw new PipelineRuntimeException(ContainerError.CONTAINER_0803, queue.size(), runtimeStats.getTotalRunners());
    }
  }
private void validateNotDestroyed ( ) throws PipelineRuntimeException { if ( destroyed . get ( ) ) { throw new PipelineRuntimeException ( ContainerError . CONTAINER_0803 , queue . size ( ) , runtimeStats . getTotalRunners ( ) ) ; } }
Throw an exception if the runner was already destroyed.

@throws PipelineRuntimeException
Throw an exception if the runner was already destroyed .