Skip to content
Snippets Groups Projects
Commit 66dac449 authored by Reynold Xin's avatar Reynold Xin
Browse files

Merge pull request #618 from woggling/dead-code-disttest

DistributedSuite: remove dead code
parents 5912cc49 786c97b8
No related branches found
No related tags found
No related merge requests found
...@@ -222,7 +222,6 @@ class DistributedSuite extends FunSuite with ShouldMatchers with BeforeAndAfter ...@@ -222,7 +222,6 @@ class DistributedSuite extends FunSuite with ShouldMatchers with BeforeAndAfter
sc = new SparkContext(clusterUrl, "test") sc = new SparkContext(clusterUrl, "test")
val data = sc.parallelize(Seq(true, true), 2) val data = sc.parallelize(Seq(true, true), 2)
assert(data.count === 2) // force executors to start assert(data.count === 2) // force executors to start
val masterId = SparkEnv.get.blockManager.blockManagerId
assert(data.map(markNodeIfIdentity).collect.size === 2) assert(data.map(markNodeIfIdentity).collect.size === 2)
assert(data.map(failOnMarkedIdentity).collect.size === 2) assert(data.map(failOnMarkedIdentity).collect.size === 2)
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment