diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index 1d8e7b55ecb..1a19ac76e60 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -34,6 +34,8 @@ Trunk (unreleased changes) HDFS-2663. Handle protobuf optional parameters correctly. (suresh) + HDFS-2666. Fix TestBackupNode failure. (suresh) + IMPROVEMENTS HADOOP-7524 Change RPC to allow multiple protocols including multuple diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/PBHelper.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/PBHelper.java index 34e03328411..c684ee26886 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/PBHelper.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/PBHelper.java @@ -343,16 +343,19 @@ public class PBHelper { public static CheckpointCommandProto convert(CheckpointCommand cmd) { return CheckpointCommandProto.newBuilder() - .setSignature(convert(cmd.getSignature())).build(); + .setSignature(convert(cmd.getSignature())) + .setNeedToReturnImage(cmd.needToReturnImage()).build(); } public static NamenodeCommandProto convert(NamenodeCommand cmd) { if (cmd instanceof CheckpointCommand) { return NamenodeCommandProto.newBuilder().setAction(cmd.getAction()) - .setType(NamenodeCommandProto.Type.NamenodeCommand) + .setType(NamenodeCommandProto.Type.CheckPointCommand) .setCheckpointCmd(convert((CheckpointCommand) cmd)).build(); } - return NamenodeCommandProto.newBuilder().setAction(cmd.getAction()).build(); + return NamenodeCommandProto.newBuilder() + .setType(NamenodeCommandProto.Type.NamenodeCommand) + .setAction(cmd.getAction()).build(); } public static BlockKey[] convertBlockKeys(List list) {