hdfs dfs –mkdir /tmp/modularity hdfs dfs –mkdir /tmp/modularity/graph hdfs dfs –mkdir /tmp/modularity/lpa_community
hdfs dfs –put graph500-25.e /tmp/modularity/graph
mkdir LPA_Example vim generate_data.sh ll
generate_data.sh |
---|
#/bin/bash class="LPA" test_jar_path="lpa_example_2.11-0.1.jar" executor_cores=8 num_executors=35 executor_memory=25 partition=500 java_xms="-Xms25g" echo $num_executors $executor_cores $executor_memory $partition $java_xms eval $preprocess cmd="spark-submit --class ${class} --master yarn --num-executors ${num_executors} --executor-memory ${executor_memory}g --executor-cores ${executor_cores} --driver-memory 80g --conf spark.executor.extraJavaOptions='${java_xms}' ${test_jar_path} /tmp/modularity/graph/graph500-25.e ' ' /tmp/modularity/lpa_community/graph500-25.txt '${partition}' " #echo ${cmd} eval ${cmd} |
sh generate_data.sh
hdfs dfs -ls /tmp/modularity/lpa_community/