Skip to content
This repository was archived by the owner on Oct 23, 2024. It is now read-only.

Commit 74dd009

Browse files
akirillovAlex Lembiewski
authored andcommitted
[DCOS-51454] Remove irrelevant Mesos REPL test (#54)
1 parent d91f193 commit 74dd009

File tree

1 file changed

+0
-24
lines changed

1 file changed

+0
-24
lines changed

repl/src/test/scala/org/apache/spark/repl/ReplSuite.scala

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -168,30 +168,6 @@ class ReplSuite extends SparkFunSuite {
168168
assertContains("res2: Array[Int] = Array(5, 0, 0, 0, 0)", output)
169169
}
170170

171-
if (System.getenv("MESOS_NATIVE_JAVA_LIBRARY") != null) {
172-
test("running on Mesos") {
173-
val output = runInterpreter("localquiet",
174-
"""
175-
|var v = 7
176-
|def getV() = v
177-
|sc.parallelize(1 to 10).map(x => getV()).collect().reduceLeft(_+_)
178-
|v = 10
179-
|sc.parallelize(1 to 10).map(x => getV()).collect().reduceLeft(_+_)
180-
|var array = new Array[Int](5)
181-
|val broadcastArray = sc.broadcast(array)
182-
|sc.parallelize(0 to 4).map(x => broadcastArray.value(x)).collect()
183-
|array(0) = 5
184-
|sc.parallelize(0 to 4).map(x => broadcastArray.value(x)).collect()
185-
""".stripMargin)
186-
assertDoesNotContain("error:", output)
187-
assertDoesNotContain("Exception", output)
188-
assertContains("res0: Int = 70", output)
189-
assertContains("res1: Int = 100", output)
190-
assertContains("res2: Array[Int] = Array(0, 0, 0, 0, 0)", output)
191-
assertContains("res4: Array[Int] = Array(0, 0, 0, 0, 0)", output)
192-
}
193-
}
194-
195171
test("line wrapper only initialized once when used as encoder outer scope") {
196172
val output = runInterpreter("local",
197173
"""

0 commit comments

Comments
 (0)