flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject [4/4] flink git commit: [runtime] [logging] Fix log message
Date Wed, 27 May 2015 21:05:43 GMT
[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 <uce@apache.org>
Authored: Wed May 27 18:26:46 2015 +0200
Committer: Ufuk Celebi <uce@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));
 	}


Mime
View raw message