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 fe...@apache.org on 2021/09/28 05:07:57 UTC
[hadoop] branch trunk updated: HDFS-16237.Record the BPServiceActor
information that communicates with Standby. (#3479)
This is an automated email from the ASF dual-hosted git repository.
ferhui 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 02993bc HDFS-16237.Record the BPServiceActor information that communicates with Standby. (#3479)
02993bc is described below
commit 02993bc11ef3de62c263dc988c421b96be71167e
Author: jianghuazhu <74...@qq.com>
AuthorDate: Tue Sep 28 13:07:36 2021 +0800
HDFS-16237.Record the BPServiceActor information that communicates with Standby. (#3479)
---
.../org/apache/hadoop/hdfs/server/datanode/BPOfferService.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPOfferService.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPOfferService.java
index 0c06199..7572f06 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPOfferService.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPOfferService.java
@@ -813,7 +813,8 @@ class BPOfferService {
BPServiceActor actor) throws IOException {
switch(cmd.getAction()) {
case DatanodeProtocol.DNA_ACCESSKEYUPDATE:
- LOG.info("DatanodeCommand action from standby: DNA_ACCESSKEYUPDATE");
+ LOG.info("DatanodeCommand action from standby NN {}: DNA_ACCESSKEYUPDATE",
+ actor.getNNSocketAddress());
if (dn.isBlockTokenEnabled) {
dn.blockPoolTokenSecretManager.addKeys(
getBlockPoolId(),
@@ -829,10 +830,12 @@ class BPOfferService {
case DatanodeProtocol.DNA_CACHE:
case DatanodeProtocol.DNA_UNCACHE:
case DatanodeProtocol.DNA_ERASURE_CODING_RECONSTRUCTION:
- LOG.warn("Got a command from standby NN - ignoring command:" + cmd.getAction());
+ LOG.warn("Got a command from standby NN {} - ignoring command: {}",
+ actor.getNNSocketAddress(), cmd.getAction());
break;
default:
- LOG.warn("Unknown DatanodeCommand action: " + cmd.getAction());
+ LOG.warn("Unknown DatanodeCommand action: {} from standby NN {}",
+ cmd.getAction(), actor.getNNSocketAddress());
}
return true;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org