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));
 	}