diff --git a/examples/app.yaml b/examples/app.yaml index f9418f1e..42d2620c 100644 --- a/examples/app.yaml +++ b/examples/app.yaml @@ -13,6 +13,6 @@ spec: executor: instances: 2 cores: 1 - coreLimit: 400m + coreLimit: 200m labels: foo: bar diff --git a/src/main/java/io/radanalytics/operator/app/KubernetesAppDeployer.java b/src/main/java/io/radanalytics/operator/app/KubernetesAppDeployer.java index 797a9335..bb0b9b72 100644 --- a/src/main/java/io/radanalytics/operator/app/KubernetesAppDeployer.java +++ b/src/main/java/io/radanalytics/operator/app/KubernetesAppDeployer.java @@ -58,6 +58,7 @@ private ReplicationController getSubmitterRc(SparkApplication app, String namesp command.append(" --conf spark.kubernetes.submission.waitAppCompletion=false"); command.append(" --conf spark.driver.cores=").append(driver.getCores()); command.append(" --conf spark.kubernetes.driver.limit.cores=").append(driver.getCoreLimit()); + command.append(" --conf spark.kubernetes.executor.limit.cores=").append(executor.getCoreLimit()); command.append(" --conf spark.driver.memory=").append(driver.getMemory()); if (driver.getMemoryOverhead() != null) { command.append(" --conf spark.driver.memoryOverhead=").append(driver.getMemoryOverhead());