-
Notifications
You must be signed in to change notification settings - Fork 9.2k
HDFS-14308. DFSStripedInputStream curStripeBuf is not freed by unbuff… #1667
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
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
I think the patch makes sense to me. |
| public synchronized void unbuffer() { | ||
| closeCurrentBlockReaders(); | ||
| if (curStripeBuf != null) { | ||
| curStripeBuf.clear(); |
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.
Probably a minor issue. Won't we be doing this curStripeBuf.clear() step twice in the unbuffer method? The first time is in Line #127-129.
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.
@avijayanhwx Thanks for review! Good point! It cleared twice, I removed the clear in the unbuffer. Could you help review again? Thanks!
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 changes. I am trying to understand why the parityBuf clear step was removed.
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.
@avijayanhwx Thanks for review again! The parityBuf can be cleared in method getParityBuffer() line # 133 - 140
|
💔 -1 overall
This message was automatically generated. |
|
LGTM +1 |
jojochuang
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.
+1
|
@jojochuang I saw you suggest change the "closeCurrentBlockReaders()" to "super.unbuffer()", just want to confirm, will I need to do the changes? Because I got the mail but can NOT find the comments in the PR. Thanks! |
|
💔 -1 overall
This message was automatically generated. |
|
+1 |
…er() (#1667) Reviewed-by: Aravindan Vijayan <[email protected]> Reviewed-by: Wei-Chiu Chuang <[email protected]> (cherry picked from commit 30db895) (cherry picked from commit 9316ca1)
…er() (#1667) Reviewed-by: Aravindan Vijayan <[email protected]> Reviewed-by: Wei-Chiu Chuang <[email protected]> (cherry picked from commit 30db895)
…er() (apache#1667) Reviewed-by: Aravindan Vijayan <[email protected]> Reviewed-by: Wei-Chiu Chuang <[email protected]>
…er() (apache#1667) Reviewed-by: Aravindan Vijayan <[email protected]> Reviewed-by: Wei-Chiu Chuang <[email protected]> (cherry picked from commit 30db895) (cherry picked from commit 9316ca1) (cherry picked from commit 44ca2fe) Change-Id: I6f2a60f637080fc23b99744d86b67013504c634a
…er() (apache#1667) Reviewed-by: Aravindan Vijayan <[email protected]> Reviewed-by: Wei-Chiu Chuang <[email protected]>
…er() (apache#1667) Reviewed-by: Aravindan Vijayan <[email protected]> Reviewed-by: Wei-Chiu Chuang <[email protected]> (cherry picked from commit 30db895) (cherry picked from commit 9316ca1)
…er() (apache#1667) Reviewed-by: Aravindan Vijayan <[email protected]> Reviewed-by: Wei-Chiu Chuang <[email protected]> (cherry picked from commit 30db895) (cherry picked from commit 9316ca1)
…er()
NOTICE
Please create an issue in ASF JIRA before opening a pull request,
and you need to set the title of the pull request which starts with
the corresponding JIRA issue number. (e.g. HADOOP-XXXXX. Fix a typo in YYY.)
For more details, please see https://cwiki.apache.org/confluence/display/HADOOP/How+To+Contribute