aboutsummaryrefslogtreecommitdiff
path: root/network/common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java
diff options
context:
space:
mode:
Diffstat (limited to 'network/common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java')
-rw-r--r--network/common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java5
1 files changed, 5 insertions, 0 deletions
diff --git a/network/common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java b/network/common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java
index f76bb49e87..f0363830b6 100644
--- a/network/common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java
+++ b/network/common/src/main/java/org/apache/spark/network/protocol/ChunkFetchFailure.java
@@ -53,6 +53,11 @@ public final class ChunkFetchFailure implements ResponseMessage {
}
@Override
+ public int hashCode() {
+ return Objects.hashCode(streamChunkId, errorString);
+ }
+
+ @Override
public boolean equals(Object other) {
if (other instanceof ChunkFetchFailure) {
ChunkFetchFailure o = (ChunkFetchFailure) other;