Skip to content

Commit

Permalink
[SPARK-36273][SHUFFLE] Fix identical values comparison
Browse files Browse the repository at this point in the history
This commit fixes the use of the "o.appAttemptId" variable instead of the mistaken "appAttemptId" variable. The current situation is a comparison of identical values. Jira issue report SPARK-36273.

### What changes were proposed in this pull request?
This is a patch for SPARK-35546 which is needed for push-based shuffle.

### Why are the changes needed?
A very minor fix of adding the reference from the other "FinalizeShuffleMerge".

### Does this PR introduce _any_ user-facing change?
No.

### How was this patch tested?
No unit tests were added. It's a pretty logical change.

Closes apache#33493 from almogtavor/patch-1.

Authored-by: Almog Tavor <[email protected]>
Signed-off-by: Sean Owen <[email protected]>
  • Loading branch information
almogtavor authored and srowen committed Jul 23, 2021
1 parent fc29c91 commit 530c8ad
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ public boolean equals(Object other) {
if (other != null && other instanceof FinalizeShuffleMerge) {
FinalizeShuffleMerge o = (FinalizeShuffleMerge) other;
return Objects.equal(appId, o.appId)
&& appAttemptId == appAttemptId
&& appAttemptId == o.appAttemptId
&& shuffleId == o.shuffleId;
}
return false;
Expand Down

0 comments on commit 530c8ad

Please sign in to comment.