Repository: hadoop Updated Branches: refs/heads/branch-2.8.2 bc91e2310 -> f4208415e
HDFS-12364. [branch-2.8.2] Fix the Compile Error after HDFS-12299(addendum to HDFS-12299). Contributed by Jiandan Yang. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/f4208415 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f4208415 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f4208415 Branch: refs/heads/branch-2.8.2 Commit: f4208415eef78942d0e9de6e9385b4988bba5328 Parents: bc91e23 Author: Brahma Reddy Battula <[email protected]> Authored: Mon Aug 28 22:27:40 2017 +0800 Committer: Brahma Reddy Battula <[email protected]> Committed: Mon Aug 28 22:27:40 2017 +0800 ---------------------------------------------------------------------- .../apache/hadoop/hdfs/TestClientProtocolForPipelineRecovery.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/f4208415/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestClientProtocolForPipelineRecovery.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestClientProtocolForPipelineRecovery.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestClientProtocolForPipelineRecovery.java index fe06936..3921435 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestClientProtocolForPipelineRecovery.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestClientProtocolForPipelineRecovery.java @@ -726,7 +726,7 @@ public class TestClientProtocolForPipelineRecovery { DFSOutputStream dfsOut = (DFSOutputStream) out.getWrappedStream(); DatanodeInfo[] pipeline = dfsOut.getPipeline(); DataNode dn1 = cluster.getDataNode(pipeline[0].getIpcPort()); - dn1.setHeartbeatsDisabledForTests(true); + DataNodeTestUtils.setHeartbeatsDisabledForTests(dn1, true); DatanodeDescriptor dn1Desc = cluster.getNamesystem(0).getBlockManager() .getDatanodeManager().getDatanode(dn1.getDatanodeId()); cluster.setDataNodeDead(dn1Desc); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
