From 4ec8424e5d8c3f4d802aaacb05cd39d9633eddf8 Mon Sep 17 00:00:00 2001 From: Suresh Srinivas Date: Tue, 13 Dec 2011 17:59:37 +0000 Subject: [PATCH] HDFS-2666. Fix TestBackupNode failure. Contributed by Suresh Srinivas. git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1213808 13f79535-47bb-0310-9956-ffa450edef68 --- hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt | 2 ++ .../java/org/apache/hadoop/hdfs/protocolPB/PBHelper.java | 9 ++++++--- 2 files changed, 8 insertions(+), 3 deletions(-) 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 static RemoteEditLogManifest convert( 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) {