big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-13712. BlockReaderRemote.read() logging improvement. Contributed by Gergo Repas.

Browse Source
This commit is contained in:
Andrew Wang 2018-07-03 11:07:45 +02:00
parent d9ba6f3656
commit 344f324710
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/client/impl/BlockReaderRemote.java
View File

@ -129,16 +129,22 @@ public Peer getPeer() {
@Override @Override
public synchronized int read(byte[] buf, int off, int len) public synchronized int read(byte[] buf, int off, int len)
throws IOException { throws IOException {
UUID randomId = (LOG.isTraceEnabled() ? UUID.randomUUID() : null); boolean logTraceEnabled = LOG.isTraceEnabled();
UUID randomId = null;
if (logTraceEnabled) {
randomId = UUID.randomUUID();
LOG.trace("Starting read #{} file {} from datanode {}", LOG.trace("Starting read #{} file {} from datanode {}",
randomId, filename, datanodeID.getHostName()); randomId, filename, datanodeID.getHostName());
}
if (curDataSlice == null || if (curDataSlice == null ||
curDataSlice.remaining() == 0 && bytesNeededToFinish > 0) { curDataSlice.remaining() == 0 && bytesNeededToFinish > 0) {
readNextPacket(); readNextPacket();
} }
if (logTraceEnabled) {
LOG.trace("Finishing read #{}", randomId); LOG.trace("Finishing read #{}", randomId);
}
if (curDataSlice.remaining() == 0) { if (curDataSlice.remaining() == 0) {
// we're at EOF now // we're at EOF now