BPOfferService.blockReport should call blockReportCompleted in a finnaly
@@ -1138,8 +1138,10 @@ void notifyNamenodeDeletedBlockInt(
} finally {
// In case of un/successful block reports we have to inform the leader that
// block reporting has finished for now.
+ if (blkReportHander != null) {
getLeaderActor().blockReportCompleted(bpRegistration);
}
+ }
// Log the block report processing stats from Datanode perspective
long brSendCost = now() - brSendStartTime;
