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 1779374f573..0bf75a5d0f5 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 @@ -221,6 +221,9 @@ class IncrementalBlockReportManager { // 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); } } }