Examples of triggerBlockReports()

Examples of org.apache.hadoop.hdfs.MiniDFSCluster.triggerBlockReports()

100
101
102
103
104
105
106
107
108
109
110
      // standby nn doesn't need to invalidate blocks.
      assertEquals(0,
          nn2.getNamesystem().getBlockManager().getPendingDeletionBlocksCount());

      cluster.triggerHeartbeats();
      cluster.triggerBlockReports();

      // standby nn doesn't need to invalidate blocks.
      assertEquals(0,
          nn2.getNamesystem().getBlockManager().getPendingDeletionBlocksCount());
View Full Code Here

Examples of org.apache.hadoop.hdfs.MiniDFSCluster.triggerBlockReports()

104
105
106
107
108
109
110
111
112
113
114
      waitForBlockLocations(cluster, nn2, TEST_FILE, 3);

      // Trigger immediate heartbeats and block reports so
      // that the active "trusts" all of the DNs
      cluster.triggerHeartbeats();
      cluster.triggerBlockReports();

      // Change replication
      LOG.info("Changing replication to 1");
      fs.setReplication(TEST_FILE_PATH, (short)1);
      waitForBlockLocations(cluster, nn1, TEST_FILE, 1);
View Full Code Here

Examples of org.apache.hadoop.hdfs.MiniDFSCluster.triggerBlockReports()

74
75
76
77
78
79
80
81
82
83
84
        DFSTestUtil.appendFile(fs, fileToAppend, "data");
      }

      // Ensure that blocks have been reported to the SBN ahead of the edits
      // arriving.
      cluster.triggerBlockReports();

      // Failover the current standby to active.
      cluster.shutdownNameNode(0);
      cluster.transitionToActive(1);
     
View Full Code Here

Examples of org.apache.hadoop.hdfs.MiniDFSCluster.triggerBlockReports()

96
97
98
99
100
101
102
103
104
105
106
      waitForBlockLocations(cluster, nn2, TEST_FILE, 3);

      // Trigger immediate heartbeats and block reports so
      // that the active "trusts" all of the DNs
      cluster.triggerHeartbeats();
      cluster.triggerBlockReports();

      // Change replication
      LOG.info("Changing replication to 1");
      fs.setReplication(TEST_FILE_PATH, (short)1);
      BlockManagerTestUtil.computeAllPendingWork(
View Full Code Here

Examples of org.apache.hadoop.hdfs.MiniDFSCluster.triggerBlockReports()

96
97
98
99
100
101
102
103
104
105
106
      waitForBlockLocations(cluster, nn2, TEST_FILE, 3);

      // Trigger immediate heartbeats and block reports so
      // that the active "trusts" all of the DNs
      cluster.triggerHeartbeats();
      cluster.triggerBlockReports();

      // Change replication
      LOG.info("Changing replication to 1");
      fs.setReplication(TEST_FILE_PATH, (short)1);
      BlockManagerTestUtil.computeAllPendingWork(
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.