This is an automated email from the ASF dual-hosted git repository.
ayushsaxena pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new c491f81 HDFS-16078. Remove unused parameters for
DatanodeManager.handleLifeline() (#3119). Contributed by tomscut.
c491f81 is described below
commit c491f81a30162eb294bcccbc64b771f95231ea21
Author: litao <tomlees...@gmail.com>
AuthorDate: Sun Jun 20 12:50:52 2021 +0800
HDFS-16078. Remove unused parameters for DatanodeManager.handleLifeline()
(#3119). Contributed by tomscut.
Signed-off-by: Wei-Chiu Chuang <weic...@apache.org>
Signed-off-by: Ayush Saxena <ayushsax...@apache.org>
---
.../apache/hadoop/hdfs/server/blockmanagement/DatanodeManager.java | 6 ++----
.../java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java | 3 +--
2 files changed, 3 insertions(+), 6 deletions(-)
diff --git
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeManager.java
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeManager.java
index 67811c9..2e7b338 100644
---
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeManager.java
+++
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/DatanodeManager.java
@@ -1876,18 +1876,16 @@ public class DatanodeManager {
*
* @param nodeReg registration info for DataNode sending the lifeline
* @param reports storage reports from DataNode
- * @param blockPoolId block pool ID
* @param cacheCapacity cache capacity at DataNode
* @param cacheUsed cache used at DataNode
* @param xceiverCount estimated count of transfer threads running at
DataNode
- * @param maxTransfers count of transfers running at DataNode
* @param failedVolumes count of failed volumes at DataNode
* @param volumeFailureSummary info on failed volumes at DataNode
* @throws IOException if there is an error
*/
public void handleLifeline(DatanodeRegistration nodeReg,
- StorageReport[] reports, String blockPoolId, long cacheCapacity,
- long cacheUsed, int xceiverCount, int maxTransfers, int failedVolumes,
+ StorageReport[] reports, long cacheCapacity,
+ long cacheUsed, int xceiverCount, int failedVolumes,
VolumeFailureSummary volumeFailureSummary) throws IOException {
if (LOG.isDebugEnabled()) {
LOG.debug("Received handleLifeline from nodeReg = " + nodeReg);
diff --git
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
index 32da3c7..7ccaae9 100644
---
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
+++
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
@@ -4416,9 +4416,8 @@ public class FSNamesystem implements Namesystem,
FSNamesystemMBean,
long cacheCapacity, long cacheUsed, int xceiverCount, int
xmitsInProgress,
int failedVolumes, VolumeFailureSummary volumeFailureSummary)
throws IOException {
- int maxTransfer = blockManager.getMaxReplicationStreams() -
xmitsInProgress;
blockManager.getDatanodeManager().handleLifeline(nodeReg, reports,
- getBlockPoolId(), cacheCapacity, cacheUsed, xceiverCount, maxTransfer,
+ cacheCapacity, cacheUsed, xceiverCount,
failedVolumes, volumeFailureSummary);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
