Github user juliuszsompolski commented on a diff in the pull request:
https://github.com/apache/spark/pull/19181#discussion_r141843494
--- Diff:
core/src/test/scala/org/apache/spark/memory/TestMemoryManager.scala ---
@@ -58,11 +58,15 @@ class TestMemoryManager(conf: SparkConf)
override def maxOffHeapStorageMemory: Long = 0L
- private var oomOnce = false
+ private var conseqOOM = 0
private var available = Long.MaxValue
def markExecutionAsOutOfMemoryOnce(): Unit = {
- oomOnce = true
+ markConseqOOM(1)
+ }
+
+ def markConseqOOM( n : Int) : Unit = {
--- End diff --
nit: ws: `(n: Int): Unit`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
