[incubator-celeborn] branch main updated: [CELEBORN-230] AppDiskUsageSnapShot overrides equals() without override hashCode() (#1172)

[zhouky]

This is an automated email from the ASF dual-hosted git repository.

zhouky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new 2b6822e3 [CELEBORN-230] AppDiskUsageSnapShot overrides equals() 
without override hashCode() (#1172)
2b6822e3 is described below

commit 2b6822e3c7eda95b390461c5e5399b04095cd821
Author: Kaijie Chen <c...@apache.org>
AuthorDate: Wed Jan 18 17:21:32 2023 +0800

    [CELEBORN-230] AppDiskUsageSnapShot overrides equals() without override 
hashCode() (#1172)
---
 .../scala/org/apache/celeborn/common/meta/AppDiskUsageMetric.scala   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/common/src/main/scala/org/apache/celeborn/common/meta/AppDiskUsageMetric.scala
 
b/common/src/main/scala/org/apache/celeborn/common/meta/AppDiskUsageMetric.scala
index 563243b0..00f1a9fb 100644
--- 
a/common/src/main/scala/org/apache/celeborn/common/meta/AppDiskUsageMetric.scala
+++ 
b/common/src/main/scala/org/apache/celeborn/common/meta/AppDiskUsageMetric.scala
@@ -18,6 +18,7 @@
 package org.apache.celeborn.common.meta
 
 import java.time.{Instant, LocalDateTime, ZoneId}
+import java.util.Objects
 import java.util.concurrent.TimeUnit
 import java.util.concurrent.atomic.AtomicReference
 
@@ -97,6 +98,10 @@ class AppDiskUsageSnapShot(val topItemCount: Int) extends 
Logging with Serializa
     obj.asInstanceOf[AppDiskUsageSnapShot].topNItems.zip(topNItems).forall { 
case (x, y) => x == y }
   }
 
+  override def hashCode(): Int = {
+    Objects.hashCode(topItemCount, startSnapShotTime, endSnapShotTime, 
topNItems)
+  }
+
   override def toString(): String = {
     val zoneId = ZoneId.systemDefault()
     s"Snapshot " +