You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/05/27 23:05:43 UTC
[4/4] flink git commit: [runtime] [logging] Fix log message
[runtime] [logging] Fix log message
This closes #736.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/087571bd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/087571bd
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/087571bd
Branch: refs/heads/master
Commit: 087571bda5e8d44536867aa77d8a62ed9715c951
Parents: 28eb274
Author: Ufuk Celebi <uc...@apache.org>
Authored: Wed May 27 18:26:46 2015 +0200
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Wed May 27 23:05:00 2015 +0200
----------------------------------------------------------------------
.../runtime/io/network/netty/PartitionRequestServerHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/087571bd/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java
index 15a9951..90c93e5 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java
@@ -134,7 +134,7 @@ class PartitionRequestServerHandler extends SimpleChannelInboundHandler<NettyMes
}
private void respondWithError(ChannelHandlerContext ctx, Throwable error, InputChannelID sourceId) {
- LOG.debug("Responding with error {}.", error);
+ LOG.debug("Responding with error: {}.", error.getClass());
ctx.writeAndFlush(new NettyMessage.ErrorResponse(error, sourceId));
}