fix 5% increase check

wypoon · Aug 23, 2018 · a6f9039 · a6f9039
1 parent 007f634
commit a6f9039
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/com/cloudera/spark/MemoryMonitor.scala b/core/src/main/scala/com/cloudera/spark/MemoryMonitor.scala
@@ -340,14 +340,14 @@ case object Always extends PeakReporting {
 case object IncrementBytes extends PeakReporting {
   override def report(orig: Long, update: Long): Boolean = {
     val delta = update - orig
-    delta > 1e7.toInt && (delta.toDouble / orig) > 1.05
+    delta > 1e7.toInt && (update.toDouble / orig) > 1.05
   }
 }
 
 case object IncrementCounts extends PeakReporting {
   override def report(orig: Long, update: Long): Boolean = {
     val delta = update - orig
-    delta > 100.toInt && (delta.toDouble / orig) > 1.05
+    delta > 100 && (update.toDouble / orig) > 1.05
   }
 }