Skip to content

Commit 7898f1b

Browse files
committed
to retrived spark params for differnt format log files
1 parent f1b35ad commit 7898f1b

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

get_spark_params.sh

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ gc_threads=`grep "spark.executor.extraJavaOptions" $logfile | head -1 |cut -f3 -
1313
exec_memoryOverhead=`grep "spark.yarn.executor.memoryOverhead" $logfile | head -1 | sed 's/->//' | sed 's/,/ /' | sed 's/)//' | sed 's/(//' |awk {'print $2'}`
1414
driver_memoryOverhead=`grep "spark.yarn.driver.memoryOverhead" $logfile | head -1 | sed 's/->//' | sed 's/,/ /' | sed 's/)//' | sed 's/(//' |awk {'print $2'}`
1515

16+
1617
echo "{" >${WORKDIR}/spark_params
1718
echo "\"num_executors\":\"$num_executors\"," >>${WORKDIR}/spark_params
1819
echo "\"executor_cores\":\"$executor_cores\"," >>${WORKDIR}/spark_params

0 commit comments

Comments
 (0)