Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6029#discussion_r189858273
--- 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 --
@zentol Should I open a new issue to fix this ?
---
