@@ -207,10 +207,10 @@ private List<String> buildSparkSubmitCommand(Map<String, String> env) throws IOE
207207 // - default value (512m)
208208 // Take Thrift Server as daemon
209209 String tsMemory =
210- isThriftServer (mainClass ) ? System .getenv ("SPARK_DAEMON_MEMORY" ) : null ;
210+ isThriftServer (mainClass ) ? System .getenv ("SPARK_DAEMON_MEMORY" ) : null ;
211211 String memory = firstNonEmpty (tsMemory ,
212- firstNonEmptyValue (SparkLauncher .DRIVER_MEMORY , conf , props ),
213- System .getenv ("SPARK_DRIVER_MEMORY" ), System .getenv ("SPARK_MEM" ), DEFAULT_MEM );
212+ firstNonEmptyValue (SparkLauncher .DRIVER_MEMORY , conf , props ),
213+ System .getenv ("SPARK_DRIVER_MEMORY" ), System .getenv ("SPARK_MEM" ), DEFAULT_MEM );
214214 cmd .add ("-Xms" + memory );
215215 cmd .add ("-Xmx" + memory );
216216 addOptionString (cmd , firstNonEmptyValue (SparkLauncher .DRIVER_EXTRA_JAVA_OPTIONS , conf , props ));
@@ -305,7 +305,7 @@ private boolean isClientMode(Properties userProps) {
305305 */
306306 private boolean isThriftServer (String mainClass ) {
307307 return (mainClass != null &&
308- mainClass .equals ("org.apache.spark.sql.hive.thriftserver.HiveThriftServer2" ));
308+ mainClass .equals ("org.apache.spark.sql.hive.thriftserver.HiveThriftServer2" ));
309309 }
310310
311311
0 commit comments