List of registerPrimarySsId() Examples

Examples of registerPrimarySsId()

org.apache.hadoop.hdfs.AvatarZooKeeperClient.registerPrimarySsId()
Creates a node in zookeeper denoting the current session id of the primary avatarnode of the cluster. The primary avatarnode always syncs this information to zookeeper when it starts. @param address the address of the cluster, used to create the path name for the znode @param ssid the session id of the primary avatarnode @throws IOException

Examples of org.apache.hadoop.hdfs.AvatarZooKeeperClient.registerPrimarySsId()

    int tries = 0;
    while (tries < maxTries) {
      AvatarZooKeeperClient zk = new AvatarZooKeeperClient(conf, null);
      try {
        ssid = now();
        zk.registerPrimarySsId(getClusterAddress(conf), ssid);
        // Be extra careful and verify the data was synced to zk.
        Long ssIdInZk = zk.getPrimarySsId(getClusterAddress(conf));
        if (ssid != ssIdInZk) {
          throw new IOException("Session Id in the NameNode : " + ssid +
              " does not match the session Id in Zookeeper : " + ssIdInZk);

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.