Fix to update cluster nodes in consistent hash ring in getCurrentNode…

…Name (qubole#467)

rubix-spi/src/main/java/com/qubole/rubix/spi/ClusterManager.java

@@ -166,14 +166,18 @@ public List<String> getNodes()
 
   public String getCurrentNodeName()
   {
-    if (currentNodeName == null) {
-      // getNodes() updates the currentNodeName
-      List<String> nodes = getNodes();
-      if (nodes == null) {
-        log.error("Initialization not done for Cluster Type: " + getClusterType());
-        throw new RuntimeException("Unable to find current node name");
-      }
-    }
+    // refresh cluster nodes first, which updates currentNodeName if it is not set.
+    refreshClusterNodes();
     return currentNodeName;
   }
+
+  private void refreshClusterNodes()
+  {
+    // getNodes() updates the currentNodeName
+    List<String> nodes = getNodes();
+    if (nodes == null) {
+      log.error("Initialization not done for Cluster Type: " + getClusterType());
+      throw new RuntimeException("Unable to find current node name");
+    }
+  }
 }