fix a test

mengxr · mengxr · commit 46d332d924c3 · 2014-06-19T03:58:00.000-07:00
diff --git a/core/src/test/scala/org/apache/spark/scheduler/CoarseGrainedSchedulerBackendSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/CoarseGrainedSchedulerBackendSuite.scala
@@ -35,7 +35,7 @@ class CoarseGrainedSchedulerBackendSuite extends FunSuite with LocalSparkContext
     val thrown = intercept[SparkException] {
       larger.collect()
     }
-    assert(thrown.getMessage.contains("Consider using broadcast variables for large values"))
+    assert(thrown.getMessage.contains("using broadcast variables for large values"))
     val smaller = sc.parallelize(1 to 4).collect()
     assert(smaller.size === 4)
   }

Original file line number	Diff line number	Diff line change
`@@ -35,7 +35,7 @@ class CoarseGrainedSchedulerBackendSuite extends FunSuite with LocalSparkContext`
`35`	`35`	`val thrown = intercept[SparkException] {`
`36`	`36`	`larger.collect()`
`37`	`37`	`}`
`38`		`- assert(thrown.getMessage.contains("Consider using broadcast variables for large values"))`
	`38`	`+ assert(thrown.getMessage.contains("using broadcast variables for large values"))`
`39`	`39`	`val smaller = sc.parallelize(1 to 4).collect()`
`40`	`40`	`assert(smaller.size === 4)`
`41`	`41`	`}`