File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed
main/scala/org/apache/spark/scheduler
test/scala/org/apache/spark/scheduler Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -57,7 +57,7 @@ class DAGScheduler(
57
57
private [scheduler] val listenerBus : LiveListenerBus ,
58
58
mapOutputTracker : MapOutputTrackerMaster ,
59
59
blockManagerMaster : BlockManagerMaster ,
60
- private [scheduler] val env : SparkEnv )
60
+ env : SparkEnv )
61
61
extends Logging {
62
62
63
63
import DAGScheduler ._
Original file line number Diff line number Diff line change @@ -24,7 +24,6 @@ import scala.language.reflectiveCalls
24
24
import akka .actor ._
25
25
import akka .testkit .{ImplicitSender , TestKit , TestActorRef }
26
26
import org .scalatest .{BeforeAndAfter , FunSuite }
27
- import org .scalatest .matchers .MustMatchers
28
27
29
28
import org .apache .spark ._
30
29
import org .apache .spark .rdd .RDD
@@ -39,7 +38,7 @@ class BuggyDAGEventProcessActor extends Actor {
39
38
}
40
39
41
40
class DAGSchedulerSuite extends TestKit (ActorSystem (" DAGSchedulerSuite" )) with FunSuite
42
- with MustMatchers with ImplicitSender with BeforeAndAfter with LocalSparkContext {
41
+ with ImplicitSender with BeforeAndAfter with LocalSparkContext {
43
42
44
43
val conf = new SparkConf
45
44
/** Set of TaskSets the DAGScheduler has requested executed. */
You can’t perform that action at this time.
0 commit comments