public static void clean() {
    File pipeConsensusDir =
        new File(
            ConfigNodeDescriptor.getInstance().getConf().getConsensusDir()
                + File.separator
                + PipeSnapshotResourceManager.PIPE_SNAPSHOT_DIR_NAME);
    if (pipeConsensusDir.isDirectory()) {
      LOGGER.info("Pipe snapshot dir found, deleting it: {},", pipeConsensusDir);
      FileUtils.deleteFileOrDirectory(pipeConsensusDir);
    }
  }
Delete the snapshot directory of pipe.
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/PipeConfigNodeCopiedFileDirStartupCleaner.java