From f72bd909b40a31145544cd165223295e78d2353e Mon Sep 17 00:00:00 2001 From: dv Date: Mon, 18 Sep 2017 11:24:42 -0400 Subject: [PATCH] Try shutdown of individual nodes to get around hanging RiakClient#shutdown (https://github.com/basho/riak-java-client/issues/706). --- src/main/java/org/commonvox/bigdatademos/RiakTest.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/main/java/org/commonvox/bigdatademos/RiakTest.java b/src/main/java/org/commonvox/bigdatademos/RiakTest.java index 26830e1..413fe7e 100644 --- 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(); + } + } }