Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6029#discussion_r188936871
  
    --- Diff: 
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
 ---
    @@ -303,7 +303,7 @@ public void operationComplete(ChannelFuture future) 
throws Exception {
                                        LOG.debug("Request {} was successfully 
answered after {} ms.", request, durationMillis);
                                        
stats.reportSuccessfulRequest(durationMillis);
                                } else {
    -                                   LOG.debug("Request {} failed after {} 
ms : ", request, durationMillis, future.cause());
    +                                   LOG.debug("Request {} failed after {} 
ms caused by : {}.", request, durationMillis, future.cause());
    --- End diff --
    
    `future.cause()` returns a Throwable, why is this change necessary?


---

Reply via email to