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 he...@apache.org on 2021/04/01 03:32:27 UTC
[hadoop] branch trunk updated: HDFS-15921. Improve the log for the
Storage Policy Operations. Contributed by Bhavik Patel.
This is an automated email from the ASF dual-hosted git repository.
hexiaoqiao 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 5eca748 HDFS-15921. Improve the log for the Storage Policy Operations. Contributed by Bhavik Patel.
5eca748 is described below
commit 5eca7489705834c938b685a253ca8ccaa4a8645a
Author: He Xiaoqiao <he...@apache.org>
AuthorDate: Thu Apr 1 11:32:03 2021 +0800
HDFS-15921. Improve the log for the Storage Policy Operations. Contributed by Bhavik Patel.
---
.../main/java/org/apache/hadoop/hdfs/server/namenode/FSDirAttrOp.java | 4 ++++
.../org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java | 4 ++++
2 files changed, 8 insertions(+)
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirAttrOp.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirAttrOp.java
index 164368d..173348f 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirAttrOp.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSDirAttrOp.java
@@ -434,6 +434,8 @@ public class FSDirAttrOp {
}
final int snapshotId = iip.getLatestSnapshotId();
if (inode.isFile()) {
+ FSDirectory.LOG.debug("DIR* FSDirAAr.unprotectedSetStoragePolicy for " +
+ "File.");
if (policyId != HdfsConstants.BLOCK_STORAGE_POLICY_ID_UNSPECIFIED) {
BlockStoragePolicy newPolicy = bm.getStoragePolicy(policyId);
if (newPolicy.isCopyOnCreateFile()) {
@@ -452,6 +454,8 @@ public class FSDirAttrOp {
}
inode.asFile().setStoragePolicyID(policyId, snapshotId);
} else if (inode.isDirectory()) {
+ FSDirectory.LOG.debug("DIR* FSDirAAr.unprotectedSetStoragePolicy for " +
+ "Directory.");
setDirStoragePolicy(fsd, iip, policyId);
} else {
throw new FileNotFoundException(iip.getPath()
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java
index 0767a18..aee4f68 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java
@@ -854,6 +854,7 @@ public class NameNodeRpcServer implements NamenodeProtocols {
public void unsetStoragePolicy(String src)
throws IOException {
checkNNStartup();
+ stateChangeLog.debug("*DIR* NameNode.unsetStoragePolicy for path: {}", src);
namesystem.unsetStoragePolicy(src);
}
@@ -861,12 +862,15 @@ public class NameNodeRpcServer implements NamenodeProtocols {
public void setStoragePolicy(String src, String policyName)
throws IOException {
checkNNStartup();
+ stateChangeLog.debug("*DIR* NameNode.setStoragePolicy for path: {}, " +
+ "policyName: {}", src, policyName);
namesystem.setStoragePolicy(src, policyName);
}
@Override
public BlockStoragePolicy getStoragePolicy(String path) throws IOException {
checkNNStartup();
+ stateChangeLog.debug("*DIR* NameNode.getStoragePolicy for path: {}", path);
return namesystem.getStoragePolicy(path);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org