You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ay...@apache.org on 2020/12/20 09:50:59 UTC
[hadoop] branch trunk updated: HDFS-15733. Add seqno in log when
BlockReceiver receive packet. Contributed by Haibin Huang.
This is an automated email from the ASF dual-hosted git repository.
ayushsaxena pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 3ecd362 HDFS-15733. Add seqno in log when BlockReceiver receive packet. Contributed by Haibin Huang.
3ecd362 is described below
commit 3ecd3628d45983bc7f9f410a4b6ca6959026f4ab
Author: Ayush Saxena <ay...@apache.org>
AuthorDate: Sun Dec 20 15:18:25 2020 +0530
HDFS-15733. Add seqno in log when BlockReceiver receive packet. Contributed by Haibin Huang.
---
.../org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java
index b697002..825905f 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BlockReceiver.java
@@ -537,10 +537,9 @@ class BlockReceiver implements Closeable {
packetReceiver.receiveNextPacket(in);
PacketHeader header = packetReceiver.getHeader();
- if (LOG.isDebugEnabled()){
- LOG.debug("Receiving one packet for block " + block +
- ": " + header);
- }
+ long seqno = header.getSeqno();
+ LOG.debug("Receiving one packet for block {} seqno:{} header:{} ", block,
+ seqno, header);
// Sanity check the header
if (header.getOffsetInBlock() > replicaInfo.getNumBytes()) {
@@ -556,7 +555,6 @@ class BlockReceiver implements Closeable {
}
long offsetInBlock = header.getOffsetInBlock();
- long seqno = header.getSeqno();
boolean lastPacketInBlock = header.isLastPacketInBlock();
final int len = header.getDataLen();
boolean syncBlock = header.getSyncBlock();
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org