fix(spark): cap executor cores to prevent job starvation
Spark standalone gives executors all worker cores by default. LiveDashboard was consuming all 8 cores (2 workers x 4 cores). - streaming: spark.executor.cores=1 (uses 1 core total) - batch jobs: spark.executor.cores=2 (uses 4 cores total, 2 per executor) Leaves headroom for concurrent streaming + batch. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
@@ -33,6 +33,8 @@ spec:
|
||||
- --conf
|
||||
- spark.executor.instances=2
|
||||
- --conf
|
||||
- spark.executor.cores=2
|
||||
- --conf
|
||||
- spark.executor.memory=1g
|
||||
- --conf
|
||||
- spark.driver.memory=512m
|
||||
@@ -107,6 +109,8 @@ spec:
|
||||
- --conf
|
||||
- spark.executor.instances=2
|
||||
- --conf
|
||||
- spark.executor.cores=2
|
||||
- --conf
|
||||
- spark.executor.memory=1g
|
||||
- --conf
|
||||
- spark.driver.memory=512m
|
||||
@@ -180,6 +184,8 @@ spec:
|
||||
- --conf
|
||||
- spark.executor.instances=2
|
||||
- --conf
|
||||
- spark.executor.cores=2
|
||||
- --conf
|
||||
- spark.executor.memory=1g
|
||||
- --conf
|
||||
- spark.driver.memory=512m
|
||||
@@ -254,6 +260,8 @@ spec:
|
||||
- --conf
|
||||
- spark.executor.instances=2
|
||||
- --conf
|
||||
- spark.executor.cores=2
|
||||
- --conf
|
||||
- spark.executor.memory=1g
|
||||
- --conf
|
||||
- spark.driver.memory=512m
|
||||
|
||||
@@ -53,6 +53,8 @@ spec:
|
||||
- --conf
|
||||
- spark.executor.instances=1
|
||||
- --conf
|
||||
- spark.executor.cores=1
|
||||
- --conf
|
||||
- spark.executor.memory=512m
|
||||
- --conf
|
||||
- spark.driver.memory=512m
|
||||
|
||||
Reference in New Issue
Block a user