Repository: hadoop Updated Branches: refs/heads/HDFS-9806 71f186b50 -> 7ffc80a51
HDFS-12887. [READ] Allow Datanodes with Provided volumes to start when blocks with the same id exist locally Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/7ffc80a5 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/7ffc80a5 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/7ffc80a5 Branch: refs/heads/HDFS-9806 Commit: 7ffc80a516cf0115d1d320892e69c073ad2514af Parents: 71f186b Author: Virajith Jalaparti <[email protected]> Authored: Wed Dec 6 09:42:31 2017 -0800 Committer: Virajith Jalaparti <[email protected]> Committed: Wed Dec 6 09:42:31 2017 -0800 ---------------------------------------------------------------------- .../hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/7ffc80a5/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java index f65fbbc..59ec100 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/ProvidedVolumeImpl.java @@ -208,8 +208,8 @@ class ProvidedVolumeImpl extends FsVolumeImpl { incrNumBlocks(); incDfsUsed(region.getBlock().getNumBytes()); } else { - throw new IOException("A block with id " + newReplica.getBlockId() - + " already exists in the volumeMap"); + LOG.warn("A block with id " + newReplica.getBlockId() + + " exists locally. Skipping PROVIDED replica"); } } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
