diff options
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.java | 5 |
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; |