Github user ArtRand commented on a diff in the pull request:
https://github.com/apache/spark/pull/19543#discussion_r146132173
--- Diff:
resource-managers/mesos/src/test/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterSchedulerSuite.scala
---
@@ -254,6 +254,32 @@ class MesosClusterSchedulerSuite extends SparkFunSuite
with LocalSparkContext wi
assert(networkInfos.get(0).getLabels.getLabels(1).getValue == "val2")
}
+ test("declines offers that violate driver constraints") {
+ setScheduler()
+
+ val mem = 1000
+ val cpu = 1
+ val s2Attributes = List(Utils.createTextAttribute("c", "u"))
+
+ val response = scheduler.submitDriver(
+ new MesosDriverDescription("d1", "jar", mem, cpu, true,
+ command,
+ Map("spark.mesos.executor.home" -> "test",
+ "spark.app.name" -> "test",
+ "spark.mesos.driver.constraints" -> "c:v"),
--- End diff --
maybe test multiple constraints too?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
