Merge pull request #51 from hynix/master

Update SubmitParams.java
exacaster · Jun 20, 2022 · 0ed4c08 · 0ed4c08
2 parents 5e25b61 + 8c734ba
commit 0ed4c08
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/server/src/main/java/com/exacaster/lighter/spark/SubmitParams.java b/server/src/main/java/com/exacaster/lighter/spark/SubmitParams.java
@@ -89,15 +89,15 @@ public Integer getNumExecutors() {
     }
 
     public Integer getExecutorCores() {
-        return ofNullable(executorCores).orElse(2);
+        return ofNullable(executorCores).orElse(1);
     }
 
     public String getExecutorMemory() {
         return ofNullable(executorMemory).orElse("1000M");
     }
 
     public Integer getDriverCores() {
-        return ofNullable(driverCores).orElse(2);
+        return ofNullable(driverCores).orElse(1);
     }
 
     public String getDriverMemory() {

diff --git a/server/src/test/groovy/com/exacaster/lighter/spark/SparkAppTest.groovy b/server/src/test/groovy/com/exacaster/lighter/spark/SparkAppTest.groovy
@@ -27,7 +27,7 @@ class SparkAppTest extends Specification {
         result == [
                 "spark.executor.memory":"1000M",
                 "spark.driver.memory":"1000M",
-                "spark.executor.cores":"2",
+                "spark.executor.cores":"1",
                 "spark.driver.cores":"1",
                 "spark.executor.instances":"0",
                 "spark.kubernetes.driverEnv.TEST1":"test1"