Skip to content

Commit 4463fbd

Browse files
adoroszlaiivandika3
authored andcommitted
HDDS-13175. Leftover reference to OM-specific trash implementation (apache#8563)
(cherry picked from commit 315ef20)
1 parent 4f434a1 commit 4463fbd

8 files changed

Lines changed: 13 additions & 18 deletions

File tree

hadoop-hdds/common/src/main/java/org/apache/hadoop/ozone/OzoneConfigKeys.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -632,7 +632,7 @@ public final class OzoneConfigKeys {
632632

633633
public static final String FS_TRASH_CLASSNAME = "fs.trash.classname";
634634
public static final String FS_TRASH_CLASSNAME_DEFAULT =
635-
"org.apache.hadoop.ozone.om.TrashPolicyOzone";
635+
"org.apache.hadoop.fs.ozone.OzoneTrashPolicy";
636636

637637
public static final String
638638
OZONE_OM_SNAPSHOT_COMPACTION_DAG_MAX_TIME_ALLOWED =

hadoop-hdds/common/src/main/resources/ozone-default.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2729,7 +2729,7 @@
27292729

27302730
<property>
27312731
<name>fs.trash.classname</name>
2732-
<value>org.apache.hadoop.ozone.om.TrashPolicyOzone</value>
2732+
<value>org.apache.hadoop.fs.ozone.OzoneTrashPolicy</value>
27332733
<tag>OZONE, OZONEFS, CLIENT</tag>
27342734
<description>
27352735
Trash Policy to be used.

hadoop-hdds/docs/content/interface/Ofs.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ In order to enable trash in Ozone, Please add these configs to core-site.xml
237237
</property>
238238
<property>
239239
<name>fs.trash.classname</name>
240-
<value>org.apache.hadoop.ozone.om.TrashPolicyOzone</value>
240+
<value>org.apache.hadoop.fs.ozone.OzoneTrashPolicy</value>
241241
</property>
242242
{{< /highlight >}}
243243

hadoop-hdds/docs/content/interface/Ofs.zh.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ $ ozone fs -put ./NOTICE.txt ofs://om/tmp/key1
220220
</property>
221221
<property>
222222
<name>fs.trash.classname</name>
223-
<value>org.apache.hadoop.ozone.om.TrashPolicyOzone</value>
223+
<value>org.apache.hadoop.fs.ozone.OzoneTrashPolicy</value>
224224
</property>
225225
{{< /highlight >}}
226226

hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/AbstractOzoneFileSystemTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,6 @@
111111
import org.apache.hadoop.ozone.om.OMMetrics;
112112
import org.apache.hadoop.ozone.om.OmConfig;
113113
import org.apache.hadoop.ozone.om.OzonePrefixPathImpl;
114-
import org.apache.hadoop.ozone.om.TrashPolicyOzone;
115114
import org.apache.hadoop.ozone.om.exceptions.OMException;
116115
import org.apache.hadoop.ozone.om.helpers.BucketLayout;
117116
import org.apache.hadoop.ozone.om.helpers.OmKeyArgs;
@@ -1685,7 +1684,7 @@ public void testTrash() throws Exception {
16851684
ContractTestUtils.touch(fs, path);
16861685
assertTrue(trash.getConf().getClass(
16871686
"fs.trash.classname", TrashPolicy.class).
1688-
isAssignableFrom(TrashPolicyOzone.class));
1687+
isAssignableFrom(OzoneTrashPolicy.class));
16891688
assertEquals(TRASH_INTERVAL, trash.getConf().
16901689
getFloat(OMConfigKeys.OZONE_FS_TRASH_INTERVAL_KEY, 0), 0);
16911690

hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/AbstractRootedOzoneFileSystemTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,6 @@
117117
import org.apache.hadoop.ozone.client.protocol.ClientProtocol;
118118
import org.apache.hadoop.ozone.om.OMConfigKeys;
119119
import org.apache.hadoop.ozone.om.OMMetrics;
120-
import org.apache.hadoop.ozone.om.TrashPolicyOzone;
121120
import org.apache.hadoop.ozone.om.exceptions.OMException;
122121
import org.apache.hadoop.ozone.om.helpers.BucketLayout;
123122
import org.apache.hadoop.ozone.om.helpers.QuotaUtil;
@@ -1881,7 +1880,7 @@ void testTrash() throws Exception {
18811880

18821881
assertTrue(trash.getConf().getClass(
18831882
"fs.trash.classname", TrashPolicy.class).
1884-
isAssignableFrom(TrashPolicyOzone.class));
1883+
isAssignableFrom(OzoneTrashPolicy.class));
18851884

18861885
long prevNumTrashDeletes = getOMMetrics().getNumTrashDeletes();
18871886
long prevNumTrashFileDeletes = getOMMetrics().getNumTrashFilesDeletes();

hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/shell/TestOzoneShellHA.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,7 @@
6868
import org.apache.hadoop.fs.Path;
6969
import org.apache.hadoop.fs.TrashPolicy;
7070
import org.apache.hadoop.fs.ozone.OzoneFsShell;
71+
import org.apache.hadoop.fs.ozone.OzoneTrashPolicy;
7172
import org.apache.hadoop.hdds.JsonTestUtils;
7273
import org.apache.hadoop.hdds.cli.GenericCli;
7374
import org.apache.hadoop.hdds.client.ReplicationType;
@@ -91,7 +92,6 @@
9192
import org.apache.hadoop.ozone.ha.ConfUtils;
9293
import org.apache.hadoop.ozone.om.OMConfigKeys;
9394
import org.apache.hadoop.ozone.om.OzoneManager;
94-
import org.apache.hadoop.ozone.om.TrashPolicyOzone;
9595
import org.apache.hadoop.ozone.om.exceptions.OMException;
9696
import org.apache.hadoop.ozone.om.helpers.BucketLayout;
9797
import org.apache.hadoop.ozone.om.helpers.OzoneFileStatus;
@@ -993,17 +993,17 @@ private OzoneConfiguration getClientConfForOFS(
993993

994994
/**
995995
* Helper function to retrieve Ozone client configuration for ozone
996-
* trash testing with TrashPolicyOzone.
996+
* trash testing with OzoneTrashPolicy.
997997
* @param hostPrefix Scheme + Authority. e.g. ofs://om-service-test1
998998
* @param configuration Server config to generate client config from.
999999
* @return Config ofs configuration added with fs.trash.classname
1000-
* = TrashPolicyOzone.
1000+
* = OzoneTrashPolicy.
10011001
*/
10021002
private OzoneConfiguration getClientConfForOzoneTrashPolicy(
10031003
String hostPrefix, OzoneConfiguration configuration) {
10041004
OzoneConfiguration clientConf =
10051005
getClientConfForOFS(hostPrefix, configuration);
1006-
clientConf.setClass("fs.trash.classname", TrashPolicyOzone.class,
1006+
clientConf.setClass("fs.trash.classname", OzoneTrashPolicy.class,
10071007
TrashPolicy.class);
10081008
return clientConf;
10091009
}
@@ -1189,7 +1189,7 @@ public void testDeleteTrashNoSkipTrash() throws Exception {
11891189

11901190
// Test delete from Trash directory removes item from filesystem
11911191

1192-
// setup configuration to use TrashPolicyOzone
1192+
// setup configuration to use OzoneTrashPolicy
11931193
// (default is TrashPolicyDefault)
11941194
final String hostPrefix = OZONE_OFS_URI_SCHEME + "://" + omServiceId;
11951195
OzoneConfiguration clientConf =

hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@
4848
* of TrashPolicy ozone-specific trash optimizations are/will be made such as
4949
* having a multithreaded TrashEmptier.
5050
*/
51-
public class TrashPolicyOzone extends OzoneTrashPolicy {
51+
class TrashPolicyOzone extends OzoneTrashPolicy {
5252

5353
private static final Logger LOG =
5454
LoggerFactory.getLogger(TrashPolicyOzone.class);
@@ -60,10 +60,7 @@ public class TrashPolicyOzone extends OzoneTrashPolicy {
6060
new SimpleDateFormat("yyMMddHHmm");
6161
private long emptierInterval;
6262

63-
private OzoneManager om;
64-
65-
public TrashPolicyOzone() {
66-
}
63+
private final OzoneManager om;
6764

6865
@Override
6966
public void initialize(Configuration conf, FileSystem fs) {

0 commit comments

Comments
 (0)