[ratis] branch master updated: RATIS-1452. Fix log output in sendRequest. (#547)

[szetszwo]

This is an automated email from the ASF dual-hosted git repository.

szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git


The following commit(s) were added to refs/heads/master by this push:
     new a00a66d  RATIS-1452. Fix log output in sendRequest. (#547)
a00a66d is described below

commit a00a66d6afdf1d23f24113aa28d3331f9e06e55b
Author: micah zhao <micahz...@tencent.com>
AuthorDate: Wed Dec 1 09:02:27 2021 +0800

    RATIS-1452. Fix log output in sendRequest. (#547)
---
 .../java/org/apache/ratis/client/impl/OrderedStreamAsync.java     | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

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 107e741..cec0fca 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
@@ -115,9 +115,11 @@ public class OrderedStreamAsync {
         = seqNum -> new DataStreamWindowRequest(header, data, seqNum);
     return slidingWindow.submitNewRequest(constructor, 
this::sendRequestToNetwork).
            getReplyFuture().whenComplete((r, e) -> {
-      LOG.error("Failed to send request, header=" + header, e);
-      requestSemaphore.release();
-    });
+             if (e != null) {
+               LOG.error("Failed to send request, header=" + header, e);
+             }
+             requestSemaphore.release();
+           });
   }
 
   private void sendRequestToNetwork(DataStreamWindowRequest request){