|
@@ -711,6 +711,10 @@ class BlockReceiver implements Closeable {
|
|
|
streams.writeDataToDisk(dataBuf.array(),
|
|
|
startByteToDisk, numBytesToDisk);
|
|
|
long duration = Time.monotonicNow() - begin;
|
|
|
+ if (duration > datanodeSlowLogThresholdMs) {
|
|
|
+ LOG.warn("Slow BlockReceiver write data to disk cost:" + duration
|
|
|
+ + "ms (threshold=" + datanodeSlowLogThresholdMs + "ms)");
|
|
|
+ }
|
|
|
|
|
|
if (duration > maxWriteToDiskMs) {
|
|
|
maxWriteToDiskMs = duration;
|