diff --git a/dora/underfs/hdfs/src/main/java/alluxio/underfs/hdfs/HdfsUnderFileSystem.java b/dora/underfs/hdfs/src/main/java/alluxio/underfs/hdfs/HdfsUnderFileSystem.java index a2ae5584acfc..810c3a85bd12 100755 --- a/dora/underfs/hdfs/src/main/java/alluxio/underfs/hdfs/HdfsUnderFileSystem.java +++ b/dora/underfs/hdfs/src/main/java/alluxio/underfs/hdfs/HdfsUnderFileSystem.java @@ -219,7 +219,9 @@ public Trash load(FileSystem fs) throws Exception { } } - if (StringUtils.equals("hdfs", ufsUri.getScheme())) { + if (StringUtils.equals("hdfs", ufsUri.getScheme()) + || StringUtils.equals("webhdfs", ufsUri.getScheme()) + || StringUtils.equals("swebhdfs", ufsUri.getScheme())) { try { // If this class is not loaded here, it will be later loaded by the system classloader // from alluxio server jar, but will be called by a class loaded with extension