public final void closeReceiverExecutor() {
    this.replicaReceiverMap.forEach(
        (consensusGroupId, receiverMap) -> {
          receiverMap.forEach(
              (consensusPipeName, receiverReference) -> {
                if (receiverReference != null) {
                  receiverReference.get().closeExecutor();
                  LOGGER.info("Receivers-{}' executor is closed.", consensusPipeName);
                }
              });
        });
  }
Release all receivers of given data region
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiverAgent.java