Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-16870 HDFS client ip should also be logged when NameNode is processing reportBadBlocks

This commit is contained in:
Daniel-009497 2022-12-17 18:01:08 +08:00
parent ca3526da92
commit 05137dd0ff
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
View File

@ -5884,6 +5884,7 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean,
*/ */
void reportBadBlocks(LocatedBlock[] blocks) throws IOException { void reportBadBlocks(LocatedBlock[] blocks) throws IOException {
checkOperation(OperationCategory.WRITE); checkOperation(OperationCategory.WRITE);
InetAddress remoteIp = Server.getRemoteIp();
writeLock(); writeLock();
try { try {
checkOperation(OperationCategory.WRITE); checkOperation(OperationCategory.WRITE);
@ -5893,7 +5894,7 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean,
String[] storageIDs = blocks[i].getStorageIDs(); String[] storageIDs = blocks[i].getStorageIDs();
for (int j = 0; j < nodes.length; j++) { for (int j = 0; j < nodes.length; j++) {
NameNode.stateChangeLog.info("*DIR* reportBadBlocks for block: {} on" NameNode.stateChangeLog.info("*DIR* reportBadBlocks for block: {} on"
+ " datanode: {}", blk, nodes[j].getXferAddr()); + " datanode: {}" + " client: {}", blk, nodes[j].getXferAddr(), remoteIp);
blockManager.findAndMarkBlockAsCorrupt(blk, nodes[j], blockManager.findAndMarkBlockAsCorrupt(blk, nodes[j],
storageIDs == null ? null: storageIDs[j], storageIDs == null ? null: storageIDs[j],
"client machine reported it"); "client machine reported it");