Repository: hadoop Updated Branches: refs/heads/branch-2.8 1b263ea49 -> 31843df27
HDFS-10189. PacketResponder#toString should include the downstreams for PacketResponderType.HAS_DOWNSTREAM_IN_PIPELINE (Joe Pallas via cmccabe) (cherry picked from commit a7d8f2b3960d27c74abb17ce2aa4bcd999706ad2) (cherry picked from commit a68a9eb2b131e426ad16854e83ef81418442e989) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/31843df2 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/31843df2 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/31843df2 Branch: refs/heads/branch-2.8 Commit: 31843df277cef08d10e0453b753469a4f94a3d1d Parents: 1b263ea Author: Colin Patrick Mccabe <[email protected]> Authored: Tue Mar 22 14:56:02 2016 -0700 Committer: Colin Patrick Mccabe <[email protected]> Committed: Tue Mar 22 17:22:15 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/31843df2/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java index 3040489..1a1cc27 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java @@ -1146,7 +1146,7 @@ class BlockReceiver implements Closeable { final StringBuilder b = new StringBuilder(getClass().getSimpleName()) .append(": ").append(block).append(", type=").append(type); - if (type != PacketResponderType.HAS_DOWNSTREAM_IN_PIPELINE) { + if (type == PacketResponderType.HAS_DOWNSTREAM_IN_PIPELINE) { b.append(", downstreams=").append(downstreams.length) .append(":").append(Arrays.asList(downstreams)); }
