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?
---
