@Override
  public void createSubtask() throws PipeException {
    executor.register(pipeProcessorSubtask);
  }
@param pipeName pipe name
@param creationTime pipe creation time
@param pipeProcessorParameters used to create {@link PipeProcessor}
@param regionId {@link DataRegion} id
@param pipeExtractorInputEventSupplier used to input {@link Event}s from {@link PipeExtractor}
@param pipeConnectorOutputPendingQueue used to output {@link Event}s to {@link PipeConnector}
@throws PipeException if failed to {@link PipeProcessor#validate(PipeParameterValidator)} or
    {@link PipeProcessor#customize(PipeParameters, PipeProcessorRuntimeConfiguration)}}
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/stage/PipeTaskProcessorStage.java