diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/IncrementalBlockReportManager.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/IncrementalBlockReportManager.java index 3b093a7f59013..7adde61f9b96a 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/IncrementalBlockReportManager.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/IncrementalBlockReportManager.java @@ -212,11 +212,10 @@ void sendIBRs(DatanodeProtocol namenode, DatanodeRegistration registration, namenode.blockReceivedAndDeleted(registration, bpid, reports); success = true; } finally { - + lastIBR = startTime; if (success) { dnMetrics.addIncrementalBlockReport(monotonicNow() - startTime, nnRpcLatencySuffix); - lastIBR = startTime; } else { // If we didn't succeed in sending the report, put all of the // blocks back onto our queue, but only in the case where we @@ -304,4 +303,4 @@ void clearIBRs() { int getPendingIBRSize() { return pendingIBRs.size(); } -} \ No newline at end of file +}