-
Notifications
You must be signed in to change notification settings - Fork 9.2k
HDFS-15393: Review of PendingReconstructionBlocks #2055
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
base: trunk
Are you sure you want to change the base?
Conversation
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
| synchronized (timedOutItems) { | ||
| return timedOutCount + timedOutItems.size(); | ||
| } | ||
| return timedOutCount + timedOutItems.size(); |
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.
Unlikely but this can still be technically be inconsistent, right?
| while (iterator.hasNext()) { | ||
| DatanodeStorageInfo next = iterator.next(); | ||
| if (next.getDatanodeDescriptor() == dn.getDatanodeDescriptor()) { | ||
| if (next.getDatanodeDescriptor().equals(dn.getDatanodeDescriptor())) { |
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.
This looks pretty bad... could this have had a negative impact in the past?
| fsRunning = false; | ||
| if(timerThread == null) return; | ||
| if (timerThread == null) | ||
| return; |
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.
Add keys?
| * to exit. | ||
| */ | ||
| void stop() { | ||
| fsRunning = false; |
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.
I can of like this. You think catching the interrupt is enough?
| * Iterate through all items and print them. | ||
| */ | ||
| void metaSave(PrintWriter out) { | ||
| synchronized (pendingReconstructions) { |
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.
Why is there no need anymore?
|
💔 -1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
No description provided.