Searched refs:taskCpus (Results 1 – 2 of 2) sorted by relevance
119 val taskCpus = 2 constant120 val taskScheduler = setupScheduler("spark.task.cpus" -> taskCpus.toString)139 val multiCoreWorkerOffers = IndexedSeq(new WorkerOffer("executor0", "host0", taskCpus),149 val taskCpus = 2 constant150 val taskScheduler = setupScheduler("spark.task.cpus" -> taskCpus.toString)154 val multiCoreWorkerOffers = IndexedSeq(new WorkerOffer("executor0", "host0", taskCpus),
98 taskCpus, err := cpuset.Parse(string(taskCpusRaw))100 require.Exactly(t, alloc.AllocatedResources.Tasks["web"].Cpu.ReservedCores, taskCpus.ToSlice())