private void retryTransfer(final PipeInsertionEvent tabletInsertionEvent) {
    // TODO: batch transfer
    try {
      if (transferInEventWithoutCheck(tabletInsertionEvent)) {
        tabletInsertionEvent.decreaseReferenceCount(
            PipeConsensusAsyncConnector.class.getName(), false);
      } else {
        addFailureEventToRetryQueue(tabletInsertionEvent);
      }
    } catch (final Exception e) {
      tabletInsertionEvent.decreaseReferenceCount(
          PipeConsensusAsyncConnector.class.getName(), false);
      addFailureEventToRetryQueue(tabletInsertionEvent);
    }
  }
Transfer queued {@link Event}s which are waiting for retry.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java