This is an automated email from the ASF dual-hosted git repository. dragonyliu pushed a commit to branch branch-2 in repository https://gitbox.apache.org/repos/asf/ratis.git
commit d5e3d413b3f8dc868549a246e9617f1aedc2c0cf Author: Kiyoshi Mizumaru <[email protected]> AuthorDate: Wed Aug 3 05:57:56 2022 +0900 RATIS-1655. Fix OrderedStreamAsync#scheduleWithTimeout to report a correct timeout value (#701) (cherry picked from commit 3db8f9eac82efedd51322a0d213300c9a0940bb6) --- .../src/main/java/org/apache/ratis/client/impl/OrderedStreamAsync.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ratis-client/src/main/java/org/apache/ratis/client/impl/OrderedStreamAsync.java b/ratis-client/src/main/java/org/apache/ratis/client/impl/OrderedStreamAsync.java index 5bc3242e7..ed4a20c03 100644 --- a/ratis-client/src/main/java/org/apache/ratis/client/impl/OrderedStreamAsync.java +++ b/ratis-client/src/main/java/org/apache/ratis/client/impl/OrderedStreamAsync.java @@ -170,7 +170,7 @@ public class OrderedStreamAsync { scheduler.onTimeout(timeout, () -> { if (!request.getReplyFuture().isDone()) { request.getReplyFuture().completeExceptionally( - new TimeoutIOException("Timeout " + requestTimeout + ": Failed to send " + request)); + new TimeoutIOException("Timeout " + timeout + ": Failed to send " + request)); } }, LOG, () -> "Failed to completeExceptionally for " + request); }
