-
Notifications
You must be signed in to change notification settings - Fork 148
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
[ISSUE-369] Don't throw exception if blocks are corrupted but have multi replicas #374
Conversation
@@ -82,6 +83,7 @@ public ShuffleReadClientImpl( | |||
this.blockIdBitmap = blockIdBitmap; | |||
this.taskIdBitmap = taskIdBitmap; | |||
this.idHelper = idHelper; | |||
this.shuffleServerInfoList = shuffleServerInfoList; |
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.
The size of shuffleServerInfoList will always be one because we use MultiReplicaReadHandler.
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.
No, shuffleServerInfoList
has not be modified. You can check it again.
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.
OK, my mistake.
if (expectedCrc != actualCrc) { | ||
String errMsg = "Unexpected crc value for blockId[" + bs.getBlockId() | ||
+ "], expected:" + expectedCrc + ", actual:" + actualCrc; | ||
if (shuffleServerInfoList.size() > 1) { |
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.
Could we add some comments here?
LGTM, just some nits. |
Codecov Report
@@ Coverage Diff @@
## master #374 +/- ##
============================================
- Coverage 58.01% 57.85% -0.16%
- Complexity 1361 1369 +8
============================================
Files 171 171
Lines 9006 9053 +47
Branches 787 794 +7
============================================
+ Hits 5225 5238 +13
- Misses 3449 3482 +33
- Partials 332 333 +1
📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more |
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, wait for CI, thanks @xianjingfeng
What changes were proposed in this pull request?
Don't throw exception if blocks are corrupted but have multi replicas
Why are the changes needed?
If some blocks of one replica are corrupted, maybe other replicas are not corrupted, so exception should not be thrown here if blocks have multi replicas. #369
Does this PR introduce any user-facing change?
No
How was this patch tested?
UT