public PipeReceiverStatusHandler statusHandler() {
    return receiverStatusHandler;
  }
When a pipe is dropped, the connector maybe reused and will not be closed. We need to discard
its batched or queued events in the output pipe connector.
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/protocol/IoTDBConnector.java