docs: @Override
      public void put(int partitionId, String HSIdStr) throws KeeperException, InterruptedException {
          try {
              m_zk.create(ZKUtil.joinZKPath(m_rootNode, Integer.toString(partitionId)),
                      HSIdStr.getBytes(Charsets.UTF_8),
                      Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
          }
          catch (KeeperException.NodeExistsException e) {
              m_zk.setData(ZKUtil.joinZKPath(m_rootNode, Integer.toString(partitionId)),
                      HSIdStr.getBytes(Charsets.UTF_8), -1);
          }
      }