From 8c463a2a9c38952d8efb1da4e3a6af2f29413c27 Mon Sep 17 00:00:00 2001 From: Inigo Goiri Date: Thu, 17 May 2018 14:48:04 -0700 Subject: [PATCH] HDFS-13554. TestDatanodeRegistration#testForcedRegistration does not shut down cluster. Contributed by Anbang Hu. (cherry picked from commit 65476458fa05656010809be632356e4015b59a17) --- .../hadoop/hdfs/TestDatanodeRegistration.java | 163 +++++++++--------- 1 file changed, 85 insertions(+), 78 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDatanodeRegistration.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDatanodeRegistration.java index b6ae2811066..6421e8b42a9 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDatanodeRegistration.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDatanodeRegistration.java @@ -330,86 +330,93 @@ public class TestDatanodeRegistration { conf.setInt(DFSConfigKeys.DFS_NAMENODE_HANDLER_COUNT_KEY, 4); conf.setLong(DFSConfigKeys.DFS_BLOCKREPORT_INTERVAL_MSEC_KEY, Integer.MAX_VALUE); - final MiniDFSCluster cluster = - new MiniDFSCluster.Builder(conf).numDataNodes(1).build(); - cluster.waitActive(); - cluster.getHttpUri(0); - FSNamesystem fsn = cluster.getNamesystem(); - String bpId = fsn.getBlockPoolId(); - - DataNode dn = cluster.getDataNodes().get(0); - DatanodeDescriptor dnd = - NameNodeAdapter.getDatanode(fsn, dn.getDatanodeId()); - DataNodeTestUtils.setHeartbeatsDisabledForTests(dn, true); - DatanodeStorageInfo storage = dnd.getStorageInfos()[0]; - - // registration should not change after heartbeat. - assertTrue(dnd.isRegistered()); - DatanodeRegistration lastReg = dn.getDNRegistrationForBP(bpId); - waitForHeartbeat(dn, dnd); - assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); - - // force a re-registration on next heartbeat. - dnd.setForceRegistration(true); - assertFalse(dnd.isRegistered()); - waitForHeartbeat(dn, dnd); - assertTrue(dnd.isRegistered()); - DatanodeRegistration newReg = dn.getDNRegistrationForBP(bpId); - assertNotSame(lastReg, newReg); - lastReg = newReg; - - // registration should not change on subsequent heartbeats. - waitForHeartbeat(dn, dnd); - assertTrue(dnd.isRegistered()); - assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); - assertTrue(waitForBlockReport(dn, dnd)); - assertTrue(dnd.isRegistered()); - assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); - - // check that block report is not processed and registration didn't change. - dnd.setForceRegistration(true); - assertFalse(waitForBlockReport(dn, dnd)); - assertFalse(dnd.isRegistered()); - assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); - - // heartbeat should trigger re-registration, and next block report should - // not change registration. - waitForHeartbeat(dn, dnd); - assertTrue(dnd.isRegistered()); - newReg = dn.getDNRegistrationForBP(bpId); - assertNotSame(lastReg, newReg); - lastReg = newReg; - assertTrue(waitForBlockReport(dn, dnd)); - assertTrue(dnd.isRegistered()); - assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); - - // registration doesn't change. - ExtendedBlock eb = new ExtendedBlock(bpId, 1234); - dn.notifyNamenodeDeletedBlock(eb, storage.getStorageID()); - DataNodeTestUtils.triggerDeletionReport(dn); - assertTrue(dnd.isRegistered()); - assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); - - // a failed IBR will effectively unregister the node. - boolean failed = false; + MiniDFSCluster cluster = null; try { - // pass null to cause a failure since there aren't any easy failure - // modes since it shouldn't happen. - fsn.processIncrementalBlockReport(lastReg, null); - } catch (NullPointerException npe) { - failed = true; - } - assertTrue("didn't fail", failed); - assertFalse(dnd.isRegistered()); + cluster = new MiniDFSCluster.Builder(conf).numDataNodes(1).build(); + cluster.waitActive(); + cluster.getHttpUri(0); + FSNamesystem fsn = cluster.getNamesystem(); + String bpId = fsn.getBlockPoolId(); - // should remain unregistered until next heartbeat. - dn.notifyNamenodeDeletedBlock(eb, storage.getStorageID()); - DataNodeTestUtils.triggerDeletionReport(dn); - assertFalse(dnd.isRegistered()); - assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); - waitForHeartbeat(dn, dnd); - assertTrue(dnd.isRegistered()); - assertNotSame(lastReg, dn.getDNRegistrationForBP(bpId)); + DataNode dn = cluster.getDataNodes().get(0); + DatanodeDescriptor dnd = + NameNodeAdapter.getDatanode(fsn, dn.getDatanodeId()); + DataNodeTestUtils.setHeartbeatsDisabledForTests(dn, true); + DatanodeStorageInfo storage = dnd.getStorageInfos()[0]; + + // registration should not change after heartbeat. + assertTrue(dnd.isRegistered()); + DatanodeRegistration lastReg = dn.getDNRegistrationForBP(bpId); + waitForHeartbeat(dn, dnd); + assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); + + // force a re-registration on next heartbeat. + dnd.setForceRegistration(true); + assertFalse(dnd.isRegistered()); + waitForHeartbeat(dn, dnd); + assertTrue(dnd.isRegistered()); + DatanodeRegistration newReg = dn.getDNRegistrationForBP(bpId); + assertNotSame(lastReg, newReg); + lastReg = newReg; + + // registration should not change on subsequent heartbeats. + waitForHeartbeat(dn, dnd); + assertTrue(dnd.isRegistered()); + assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); + assertTrue(waitForBlockReport(dn, dnd)); + assertTrue(dnd.isRegistered()); + assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); + + // check that block report is not processed and registration didn't + // change. + dnd.setForceRegistration(true); + assertFalse(waitForBlockReport(dn, dnd)); + assertFalse(dnd.isRegistered()); + assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); + + // heartbeat should trigger re-registration, and next block report + // should not change registration. + waitForHeartbeat(dn, dnd); + assertTrue(dnd.isRegistered()); + newReg = dn.getDNRegistrationForBP(bpId); + assertNotSame(lastReg, newReg); + lastReg = newReg; + assertTrue(waitForBlockReport(dn, dnd)); + assertTrue(dnd.isRegistered()); + assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); + + // registration doesn't change. + ExtendedBlock eb = new ExtendedBlock(bpId, 1234); + dn.notifyNamenodeDeletedBlock(eb, storage.getStorageID()); + DataNodeTestUtils.triggerDeletionReport(dn); + assertTrue(dnd.isRegistered()); + assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); + + // a failed IBR will effectively unregister the node. + boolean failed = false; + try { + // pass null to cause a failure since there aren't any easy failure + // modes since it shouldn't happen. + fsn.processIncrementalBlockReport(lastReg, null); + } catch (NullPointerException npe) { + failed = true; + } + assertTrue("didn't fail", failed); + assertFalse(dnd.isRegistered()); + + // should remain unregistered until next heartbeat. + dn.notifyNamenodeDeletedBlock(eb, storage.getStorageID()); + DataNodeTestUtils.triggerDeletionReport(dn); + assertFalse(dnd.isRegistered()); + assertSame(lastReg, dn.getDNRegistrationForBP(bpId)); + waitForHeartbeat(dn, dnd); + assertTrue(dnd.isRegistered()); + assertNotSame(lastReg, dn.getDNRegistrationForBP(bpId)); + } finally { + if (cluster != null) { + cluster.shutdown(); + } + } } private void waitForHeartbeat(final DataNode dn, final DatanodeDescriptor dnd)