Try shutdown of individual nodes to get around hanging RiakClient#shu…

…tdown (basho/riak-java-client#706).
dvimont · Sep 18, 2017 · f72bd90 · f72bd90
1 parent c6d34de
commit f72bd90
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/main/java/org/commonvox/bigdatademos/RiakTest.java b/src/main/java/org/commonvox/bigdatademos/RiakTest.java
@@ -50,7 +50,12 @@ public static void main(String [] args) throws UnknownHostException {
         System.out.println("Shutting down client!");
         // NOTE: #shutdown may hang indefinitely:
         //   https://github.com/basho/riak-java-client/issues/706
-        myNodeClient.shutdown();
+//        myNodeClient.shutdown();
+        for (RiakNode node : riakNodes) {
+            System.out.println("Shutting down NODE: " + node.getRemoteAddress());
+            node.shutdown();
+        }
+
 
     }
 }