Skip to content

Commit

Permalink
remove test
Browse files Browse the repository at this point in the history
  • Loading branch information
wangyum committed Nov 15, 2018
1 parent 44767f8 commit 965a984
Showing 1 changed file with 0 additions and 16 deletions.
Expand Up @@ -17,8 +17,6 @@

package org.apache.spark.deploy.yarn

import java.util.regex.Pattern

import scala.collection.JavaConverters._

import org.apache.hadoop.conf.Configuration
Expand All @@ -31,7 +29,6 @@ import org.mockito.Mockito._
import org.scalatest.{BeforeAndAfterEach, Matchers}

import org.apache.spark.{SecurityManager, SparkConf, SparkFunSuite}
import org.apache.spark.deploy.yarn.YarnAllocator._
import org.apache.spark.deploy.yarn.YarnSparkHadoopUtil._
import org.apache.spark.deploy.yarn.config._
import org.apache.spark.rpc.RpcEndpointRef
Expand Down Expand Up @@ -379,19 +376,6 @@ class YarnAllocatorSuite extends SparkFunSuite with Matchers with BeforeAndAfter
verify(mockAmClient).updateBlacklist(Seq[String]().asJava, Seq("hostA", "hostB").asJava)
}

test("memory exceeded diagnostic regexes") {
def logMessage(pattern: Pattern): String = {
val diagnostics =
"Container [pid=12465,containerID=container_1412887393566_0003_01_000002] is running " +
"beyond physical memory limits. Current usage: 2.1 MB of 2 GB physical memory used; " +
"5.8 GB of 4.2 GB virtual memory used. Killing container."
val matcher = pattern.matcher(diagnostics)
if (matcher.find()) " " + matcher.group() + "." else ""
}
assert(logMessage(VMEM_EXCEEDED_PATTERN).contains("5.8 GB of 4.2 GB virtual memory used."))
assert(logMessage(PMEM_EXCEEDED_PATTERN).contains("2.1 MB of 2 GB physical memory used."))
}

test("window based failure executor counting") {
sparkConf.set("spark.yarn.executor.failuresValidityInterval", "100s")
val handler = createAllocator(4)
Expand Down

0 comments on commit 965a984

Please sign in to comment.