Skip to content

Commit 8e90e55

Browse files
author
George Jahad
committed
fixed for latest client
1 parent 48a1e94 commit 8e90e55

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

resource-managers/armada/core/src/main/scala/io/armadaproject/spark/deploy/armada/ArmadaClientApplication.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,7 @@ private[spark] class ArmadaClientApplication extends SparkApplication {
250250
val (host, port) = ArmadaUtils.parseMasterUrl(sparkConf.get("spark.master"))
251251
log(s"host is $host, port is $port")
252252
val armadaClient = ArmadaClient(host, port)
253-
if (armadaClient.SubmitHealth().isServing) {
253+
if (armadaClient.submitHealth().isServing) {
254254
log("Submit health good!")
255255
} else {
256256
log("Could not contact Armada!")
@@ -363,7 +363,7 @@ private[spark] class ArmadaClientApplication extends SparkApplication {
363363
.withPodSpec(podSpec)
364364

365365
// FIXME: Plumb config for queue, job-set-id
366-
val jobSubmitResponse = armadaClient.SubmitJobs("test", "driver", Seq(driverJob))
366+
val jobSubmitResponse = armadaClient.submitJobs("test", "driver", Seq(driverJob))
367367

368368
for (respItem <- jobSubmitResponse.jobResponseItems) {
369369
val error = if (respItem.error == "") "None" else respItem.error

resource-managers/armada/core/src/main/scala/io/armadaproject/spark/scheduler/cluster/armada/ArmadaClusterManagerBackend.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ private[spark] class ArmadaClusterSchedulerBackend(
109109
.withPodSpec(podSpec)
110110

111111
val client = ArmadaClient(host, port)
112-
val jobSubmitResponse = client.SubmitJobs("test", "executor", Seq(testJob))
112+
val jobSubmitResponse = client.submitJobs("test", "executor", Seq(testJob))
113113

114114
logInfo(s"Driver Job Submit Response")
115115
for (respItem <- jobSubmitResponse.jobResponseItems) {

0 commit comments

Comments
 (0)