Skip to content

Commit c2a2909

Browse files
committed
Test compile fixes
1 parent 4ee6f9d commit c2a2909

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

core/src/test/scala/org/apache/spark/deploy/JsonProtocolSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ class JsonProtocolSuite extends FunSuite {
100100

101101
def createDriverCommand() = new Command(
102102
"org.apache.spark.FakeClass", Seq("some arg --and-some options -g foo"),
103-
Map(("K1", "V1"), ("K2", "V2")), Seq("cp1", "cp2"), Seq("lp1", "lp2"), Seq("-Dfoo")
103+
Map(("K1", "V1"), ("K2", "V2")), Seq("cp1", "cp2"), Seq("lp1", "lp2"), Some("-Dfoo")
104104
)
105105

106106
def createDriverDesc() = new DriverDescription("hdfs://some-dir/some.jar", 100, 3,

core/src/test/scala/org/apache/spark/deploy/worker/DriverRunnerTest.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ import org.apache.spark.deploy.{Command, DriverDescription}
2929

3030
class DriverRunnerTest extends FunSuite {
3131
private def createDriverRunner() = {
32-
val command = new Command("mainClass", Seq(), Map())
32+
val command = new Command("mainClass", Seq(), Map(), Seq(), Seq())
3333
val driverDescription = new DriverDescription("jarUrl", 512, 1, true, command)
3434
new DriverRunner("driverId", new File("workDir"), new File("sparkHome"), driverDescription,
3535
null, "akka://1.2.3.4/worker/")

core/src/test/scala/org/apache/spark/deploy/worker/ExecutorRunnerTest.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,8 @@ class ExecutorRunnerTest extends FunSuite {
2727
test("command includes appId") {
2828
def f(s:String) = new File(s)
2929
val sparkHome = sys.env.get("SPARK_HOME").orElse(sys.props.get("spark.home"))
30-
val appDesc = new ApplicationDescription("app name", Some(8), 500, Command("foo", Seq(),Map()),
30+
val appDesc = new ApplicationDescription("app name", Some(8), 500,
31+
Command("foo", Seq(), Map(), Seq(), Seq()),
3132
sparkHome, "appUiUrl")
3233
val appId = "12345-worker321-9876"
3334
val er = new ExecutorRunner(appId, 1, appDesc, 8, 500, null, "blah", "worker321", f(sparkHome.getOrElse(".")),

0 commit comments

Comments
 (0)