Avoid workers with no cores when over-subscribing workers

mesos · May 3, 2014 · 65f0cfe · 65f0cfe
1 parent 149c767
commit 65f0cfe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/deploy_templates.py b/deploy_templates.py
@@ -51,7 +51,7 @@
 
 worker_instances = int(os.getenv("SPARK_WORKER_INSTANCES", 1))
 # Distribute equally cpu cores among worker instances
-worker_cores = slave_cpus / worker_instances
+worker_cores = max(slave_cpus / worker_instances, 1)
 
 template_vars = {
   "master_list": os.getenv("MASTERS"),