File tree Expand file tree Collapse file tree 1 file changed +0
-3
lines changed
core/src/test/scala/org/apache/spark Expand file tree Collapse file tree 1 file changed +0
-3
lines changed Original file line number Diff line number Diff line change @@ -135,7 +135,6 @@ class DistributedSuite extends FunSuite with Matchers with BeforeAndAfter
135135 sc.parallelize(1 to 10 , 2 ).foreach { x => if (x == 1 ) System .exit(42 ) }
136136 }
137137 assert(thrown.getClass === classOf [SparkException ])
138- System .out.println(thrown.getMessage)
139138 assert(thrown.getMessage.contains(" failed 4 times" ))
140139 }
141140 }
@@ -268,8 +267,6 @@ class DistributedSuite extends FunSuite with Matchers with BeforeAndAfter
268267 DistributedSuite .amMaster = true
269268 sc = new SparkContext (clusterUrl, " test" )
270269 for (i <- 1 to 3 ) {
271- println(" i = " + i)
272- Console .out.flush()
273270 val data = sc.parallelize(Seq (true , true ), 2 )
274271 assert(data.count === 2 )
275272 assert(data.map(markNodeIfIdentity).collect.size === 2 )
You can’t perform that action at this time.
0 commit comments