You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by vi...@apache.org on 2017/12/06 17:43:09 UTC
hadoop git commit: HDFS-12887. [READ] Allow Datanodes with Provided
volumes to start when blocks with the same id exist locally
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 <vi...@apache.org>
Authored: Wed Dec 6 09:42:31 2017 -0800
Committer: Virajith Jalaparti <vi...@apache.org>
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: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org