docs: public void init(Long channelId, Long pipelineId) {
          String path = ManagePathUtils.getPipeline(channelId, pipelineId);
          String processRootPath = ManagePathUtils.getProcessRoot(channelId, pipelineId);
          String terminRootPath = ManagePathUtils.getTerminRoot(channelId, pipelineId);
          String remedyRootPath = ManagePathUtils.getRemedyRoot(channelId, pipelineId);
          String lockRootPath = ManagePathUtils.getLockRoot(channelId, pipelineId);
          String loadLockPath = lockRootPath + "/" + ArbitrateConstants.NODE_LOCK_LOAD;
          try {
              zookeeper.createPersistent(path, true);//创建父节点
              zookeeper.create(processRootPath, new byte[0], CreateMode.PERSISTENT);
              zookeeper.create(terminRootPath, new byte[0], CreateMode.PERSISTENT);
              zookeeper.create(remedyRootPath, new byte[0], CreateMode.PERSISTENT);
              zookeeper.create(lockRootPath, new byte[0], CreateMode.PERSISTENT);
              zookeeper.create(loadLockPath, new byte[0], CreateMode.PERSISTENT);
          } catch (ZkNodeExistsException e) {
              // 如果节点已经存在，则不抛异常
              // ignore
          } catch (ZkException e) {
              throw new ArbitrateException("Pipeline_init", pipelineId.toString(), e);
          }
      }