-
Notifications
You must be signed in to change notification settings - Fork 588
HDDS-4347.Make Ozone specific Trash remover multi threaded #1555
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
@sadanand48 , current unit test cases only cover the basic functionality of trash delete behavior. But here we introduce many new setting, like trash interval, emptier interval. Can we add more test case to cover this? In additional, will Ozone trash feature also support S3 semantic path later? I see currently we implement this only for FS semantic path. |
Thanks for the comment @linyiqun . Yes I will add more unit tests to this. About the trash support for the object store I don't think we'll be supporting atleast for now since s3 too doesn't support trash. |
Okay, get it, |
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/TestOzoneFileSystem.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
d455115 to
7447b94
Compare
hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/TestOzoneFileSystem.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/TestOzoneFileSystem.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/fs/ozone/TestOzoneFileSystem.java
Outdated
Show resolved
Hide resolved
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java
Outdated
Show resolved
Hide resolved
elek
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the work @sadanand48
I have a minor suggestion about config handling.
I also feel that there is no clear agreement about the followed approach (at least I didn't find the sign in the public records of the community, but I have seen a question similar to mine: why do we need FileSystem in OM side.).
I suggested in HDDS-3367 to answer to the thread on the mailing list with clarifying the chosen direction, but didn't get any answer yet. It can be useful to have everybody informed and up-to-date.
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/TrashPolicyOzone.java
Outdated
Show resolved
Hide resolved
423afa2 to
87e0376
Compare
The question has been answered on HDDS-3367. The current patch looks good to me. Resolving this comment for now. |
|
@sadanand48 , the test failures seems related, TestOzoneFileSystem#testTrash is failing in the latest run. |
|
All the checks are green. merging this change. |
I might miss but couldn't find the update on the mailing list. Would you be so kind to update this thread: |
What changes were proposed in this pull request?
This change makes the Trash Emptier multithreaded. i.e the main emptier thread starts a thread pool executor and executes tasks (checkpointing and deletion) present in the task queue. the parallelism is obtained at the bucket level as fs.trashRoots for a root OFS URI returns a list of bucket level trashroots.
What is the link to the Apache JIRA
https://issues.apache.org/jira/browse/HDDS-4347
How was this patch tested?
Added unit tests and tested manually