You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2020/05/22 17:47:04 UTC
[flink] 02/04: [hotfix][qs] Fix logging of exception in
RequestWriteListener
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 81c185bdeeccf9f10bf584defde740676d305646
Author: Gary Yao <ga...@apache.org>
AuthorDate: Thu May 21 09:30:14 2020 +0200
[hotfix][qs] Fix logging of exception in RequestWriteListener
Log stacktrace of exception instead of only the message.
---
.../org/apache/flink/queryablestate/network/AbstractServerHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
index 7941131..4115fd9 100644
--- a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
+++ b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
@@ -308,7 +308,7 @@ public abstract class AbstractServerHandler<REQ extends MessageBody, RESP extend
LOG.debug("Request {} was successfully answered after {} ms.", request, durationMillis);
stats.reportSuccessfulRequest(durationMillis);
} else {
- LOG.debug("Request {} failed after {} ms due to: {}", request, durationMillis, future.cause());
+ LOG.debug("Request {} failed after {} ms", request, durationMillis, future.cause());
stats.reportFailedRequest();
}
}