本文整理了Java中org.apache.hadoop.hdfs.server.datanode.DataNode.reportBadBlocks()方法的一些代码示例，展示了DataNode.reportBadBlocks()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。DataNode.reportBadBlocks()方法的具体详情如下：
包路径：org.apache.hadoop.hdfs.server.datanode.DataNode
类名称：DataNode
方法名：reportBadBlocks

DataNode.reportBadBlocks介绍

[英]Report a bad block which is hosted on the local DN.
[中]报告承载在本地DN上的坏块。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

/**
 * Report a bad block which is hosted on the local DN.
 */
public void reportBadBlocks(ExtendedBlock block) throws IOException{
 FsVolumeSpi volume = getFSDataset().getVolume(block);
 if (volume == null) {
  LOG.warn("Cannot find FsVolumeSpi to report bad block: {}", block);
  return;
 }
 reportBadBlocks(block, volume);
}

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

scanner.datanode.reportBadBlocks(block, volume);
} catch (IOException ie) {

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

+ " as corrupt due to length mismatch");
try {
 datanode.reportBadBlocks(new ExtendedBlock(bpid, corruptBlock),
   memBlockInfo.getVolume());
} catch (IOException e) {

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

/**
 * Report a bad block which is hosted on the local DN.
 */
public void reportBadBlocks(ExtendedBlock block) throws IOException{
 FsVolumeSpi volume = getFSDataset().getVolume(block);
 if (volume == null) {
  LOG.warn("Cannot find FsVolumeSpi to report bad block: " + block);
  return;
 }
 reportBadBlocks(block, volume);
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

private void handleScanFailure(Block block) {
 
 LOG.info("Reporting bad block " + block + " to namenode.");
 
 try {
  DatanodeInfo[] dnArr = { new DatanodeInfo(datanode.getDNRegistrationForNS(namespaceId)) };
  LocatedBlock[] blocks = { new LocatedBlock(block, dnArr) }; 
  datanode.reportBadBlocks(namespaceId,blocks);
 } catch (IOException e){
  /* One common reason is that NameNode could be in safe mode.
   * Should we keep on retrying in that case?
   */
  LOG.warn("Failed to report bad block " + block + " to namenode : " +
       " Exception : " + StringUtils.stringifyException(e));
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

/**
 * Report a bad block which is hosted on the local DN.
 */
public void reportBadBlocks(ExtendedBlock block) throws IOException{
 FsVolumeSpi volume = getFSDataset().getVolume(block);
 if (volume == null) {
  LOG.warn("Cannot find FsVolumeSpi to report bad block: " + block);
  return;
 }
 reportBadBlocks(block, volume);
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

LocatedBlock lb = new LocatedBlock(block, 
                 new DatanodeInfo[] {srcDataNode});
 datanode.reportBadBlocks(namespaceId, new LocatedBlock[] {lb});
} catch (IOException e) {
 LOG.warn("Failed to report bad block " + block +

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

+ volume.getBasePath(), e);
try {
 scanner.datanode.reportBadBlocks(block, volume);
} catch (IOException ie) {

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

+ " as corrupt due to length mismatch");
try {
 datanode.reportBadBlocks(new ExtendedBlock(bpid, corruptBlock),
   memBlockInfo.getVolume());
} catch (IOException e) {

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

+ " as corrupt due to length mismatch");
try {
 datanode.reportBadBlocks(new ExtendedBlock(bpid, corruptBlock),
   memBlockInfo.getVolume());
} catch (IOException e) {

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

+ volume.getBasePath(), e);
try {
 scanner.datanode.reportBadBlocks(block, volume);
} catch (IOException ie) {

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

try {
 dataNode.reportBadBlocks(block);
} catch (NullPointerException npe) {
 threwException = true;
dataNode.reportBadBlocks(block, dataNode.getFSDataset()
  .getVolumes().get(0));
Thread.sleep(3000);