-
Notifications
You must be signed in to change notification settings - Fork 425
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
TEZ-4129: Delete intermediate attempt data for failed attempts for Shuffle Handler #72
Conversation
@shameersss1: could you please rebase this PR and squash your commits? I believe ShuffleHandler changes should be reviewed and committed next year, we'll find a way to review those |
c2bc541
to
fd976f3
Compare
@abstractdog Thanks for looking into this. I have rebased and squash merged the commit. Please review the changes. |
This comment has been minimized.
This comment has been minimized.
fd976f3
to
931618d
Compare
🎊 +1 overall
This message was automatically generated. |
tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestTaskImpl.java
Outdated
Show resolved
Hide resolved
tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java
Outdated
Show resolved
Hide resolved
tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java
Outdated
Show resolved
Hide resolved
tez-api/src/main/java/org/apache/tez/dag/api/TezConfiguration.java
Outdated
Show resolved
Hide resolved
tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java
Outdated
Show resolved
Hide resolved
@abstractdog - Thanks for the review. I have addressed your comments. Please re-review the changes |
🎊 +1 overall
This message was automatically generated. |
ShuffleHandler.USERCACHE, user, | ||
ShuffleHandler.APPCACHE, appId.toString(), "dag_1/output/", appAttemptId}); | ||
File taskAttemptDir = new File(taskAttemptDirStr); | ||
Assert.assertTrue("Task Attempt Directory does not exist!", taskAttemptDir.exists()); |
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.
for clarity's sake, please create an Assert.assertFalse(..., taskAttemptDir.exists()) before you expect the file to appear, this way the unit test also verifies that the task attempt file wasn't present (it's not the point of the unit test, but it is worth doing)
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.
ack!
thanks @shameersss1 , 1 more very minor note |
@abstractdog I have addressed that. Please re-review the changes |
🎊 +1 overall
This message was automatically generated. |
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.
LGTM +1
I've included this patch to a cluster using tez shuffle handler, haven't found any regression
code looks straightforward and clean, I'm approving
letting this PR open for 24h if any other comments come in
@jteagles
…uffle Handler (apache#72) (Syed Shameerur Rahman reviewed by Laszlo Bodor)
Delete intermediate attempt data for failed task attempts for Tez Shuffle Handler