public synchronized void createConsensusPipeToTargetPeer(
      Peer targetPeer, boolean needManuallyStart) throws ConsensusGroupModifyPeerException {
    try {
      KillPoint.setKillPoint(DataNodeKillPoints.ORIGINAL_ADD_PEER_DONE);
      consensusPipeManager.createConsensusPipe(thisNode, targetPeer, needManuallyStart);
      peerManager.addPeer(targetPeer);
    } catch (Exception e) {
      LOGGER.warn("{} cannot create consensus pipe to {}", thisNode, targetPeer, e);
      throw new ConsensusGroupModifyPeerException(
          String.format("%s cannot create consensus pipe to %s", thisNode, targetPeer), e);
    }
  }
update given consensus pipes' status, returns the peer corresponding to the pipe that failed to
update
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java