public CommitterKey getCommitterKey(
      final String pipeName, final long creationTime, final int regionId, final int restartTime) {
    final PipeMeta pipeMeta = pipeMetaKeeper.getPipeMeta(pipeName);
    return pipeMeta == null
        ? new CommitterKey(pipeName, creationTime, regionId, restartTime)
        : ((PipeTemporaryMetaInAgent) pipeMeta.getTemporaryMeta())
            .getCommitterKey(pipeName, creationTime, regionId, restartTime);
  }
Using try lock method to prevent deadlock when stopping all pipes with critical exceptions and
{@link PipeTaskAgent#handlePipeMetaChanges(List)}} concurrently.
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTaskAgent.java