From 26df14de9126236a43be382f3c1cc7bcbba2cdce Mon Sep 17 00:00:00 2001 From: Sergey Tolmachev Date: Mon, 11 Jul 2016 18:36:04 +0300 Subject: [PATCH 1/2] Write failure cause of fetch future to update future --- .../java/com/basho/riak/client/api/commands/kv/UpdateValue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/basho/riak/client/api/commands/kv/UpdateValue.java b/src/main/java/com/basho/riak/client/api/commands/kv/UpdateValue.java index a21f071bb..753d0a43b 100644 --- a/src/main/java/com/basho/riak/client/api/commands/kv/UpdateValue.java +++ b/src/main/java/com/basho/riak/client/api/commands/kv/UpdateValue.java @@ -213,7 +213,7 @@ public void handle(RiakFuture f) } else { - updateFuture.setException(f.cause().getCause()); + updateFuture.setException(f.cause()); } } }; From 71ec6bfc81b50cb3fbb05a37407d6b95b87e01f1 Mon Sep 17 00:00:00 2001 From: Sergey Tolmachev Date: Mon, 11 Jul 2016 19:13:17 +0300 Subject: [PATCH 2/2] The same fix for store future error --- .../java/com/basho/riak/client/api/commands/kv/UpdateValue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/basho/riak/client/api/commands/kv/UpdateValue.java b/src/main/java/com/basho/riak/client/api/commands/kv/UpdateValue.java index 753d0a43b..5033725bc 100644 --- a/src/main/java/com/basho/riak/client/api/commands/kv/UpdateValue.java +++ b/src/main/java/com/basho/riak/client/api/commands/kv/UpdateValue.java @@ -583,7 +583,7 @@ public void handle(RiakFuture f) } else { - setException(f.cause().getCause()); + setException(f.cause()); } }