Skip to content

Commit ec73f17

Browse files
author
Marcelo Vanzin
committed
More review feedback.
1 parent 67f5b02 commit ec73f17

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

yarn/stable/src/test/scala/org/apache/spark/deploy/yarn/YarnClusterSuite.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,13 @@ class YarnClusterSuite extends FunSuite with BeforeAndAfterAll with Matchers {
3737
private var yarnCluster: MiniYARNCluster = _
3838
private var tempDir: File = _
3939
private var fakeSparkJar: File = _
40+
private var oldConf: Map[String, String] = _
4041

4142
override def beforeAll() {
4243
tempDir = Utils.createTempDir()
4344

45+
oldConf = sys.props.filter { case (k, v) => k.startsWith("spark.") }.toMap
46+
4447
yarnCluster = new MiniYARNCluster(getClass().getName(), 1, 1, 1)
4548
yarnCluster.init(new YarnConfiguration())
4649
yarnCluster.start()
@@ -60,6 +63,7 @@ class YarnClusterSuite extends FunSuite with BeforeAndAfterAll with Matchers {
6063
override def afterAll() {
6164
yarnCluster.stop()
6265
sys.props.retain { case (k, v) => !k.startsWith("spark.") }
66+
sys.props ++= oldConf
6367
super.afterAll()
6468
}
6569

0 commit comments

Comments
 (0)