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 9515b736a2..73cc44b31f 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 @@ -222,6 +222,9 @@ void sendIBRs(DatanodeProtocol namenode, DatanodeRegistration registration, // blocks back onto our queue, but only in the case where we // didn't put something newer in the meantime. putMissing(reports); + LOG.warn("Failed to call blockReceivedAndDeleted: {}, nnId: {}" + + ", duration(ms): {}", Arrays.toString(reports), + nnRpcLatencySuffix, monotonicNow() - startTime); } } }