From 7f5c60bef81b2df91173c001978f35ba5a8eac57 Mon Sep 17 00:00:00 2001 From: sychen Date: Tue, 10 Sep 2024 12:58:38 +0800 Subject: [PATCH] PathIsNotEmptyDirectoryException --- .../hadoop/hdfs/server/federation/router/RouterRpcServer.java | 4 +++- .../apache/hadoop/hdfs/server/namenode/NameNodeRpcServer.java | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java index 217c62ff28762..0b9d5eaa6897a 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java @@ -56,6 +56,7 @@ import java.util.stream.Collectors; import org.apache.hadoop.fs.Path; +import org.apache.hadoop.fs.PathIsNotEmptyDirectoryException; import org.apache.hadoop.hdfs.HAUtil; import org.apache.hadoop.hdfs.protocol.UnresolvedPathException; import org.apache.hadoop.thirdparty.com.google.common.cache.CacheBuilder; @@ -368,7 +369,8 @@ public RouterRpcServer(Configuration conf, Router router, NotReplicatedYetException.class, IOException.class, ConnectException.class, - RetriableException.class); + RetriableException.class, + PathIsNotEmptyDirectoryException.class); this.rpcServer.addSuppressedLoggingExceptions( StandbyException.class, UnresolvedPathException.class); 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 ec3eb4f038ec4..76100e032964d 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 @@ -54,6 +54,7 @@ import org.apache.hadoop.conf.ReconfigurationTaskStatus; import org.apache.hadoop.crypto.CryptoProtocolVersion; import org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries; +import org.apache.hadoop.fs.PathIsNotEmptyDirectoryException; import org.apache.hadoop.hdfs.AddBlockFlag; import org.apache.hadoop.fs.CacheFlag; import org.apache.hadoop.fs.CommonConfigurationKeys; @@ -541,7 +542,8 @@ public NameNodeRpcServer(Configuration conf, NameNode nn) FSLimitException.PathComponentTooLongException.class, FSLimitException.MaxDirectoryItemsExceededException.class, DisallowedDatanodeException.class, - XAttrNotFoundException.class); + XAttrNotFoundException.class, + PathIsNotEmptyDirectoryException.class); clientRpcServer.addSuppressedLoggingExceptions(StandbyException.class, UnresolvedPathException.class);