train_stat_v1.sh 997 B

1234567891011121314151617181920212223242526272829303132
  1. #!/bin/sh
  2. set -x
  3. start_date=""
  4. end_date=""
  5. if(($#==2))
  6. then
  7. start_date=$1
  8. end_date=$2
  9. else
  10. start_date=$(date +%Y%m%d -d "-15 $days day")
  11. end_date=$(date +%Y%m%d -d "-2 $days day")
  12. fi
  13. # env
  14. export SPARK_HOME=/opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8
  15. export PATH=$SPARK_HOME/bin:$PATH
  16. export HADOOP_CONF_DIR=/etc/taihao-apps/hadoop-conf
  17. export JAVA_HOME=/usr/lib/jvm/java-1.8.0
  18. # param
  19. readPath=/dw/recommend/model/831_recsys_rov_train_data/
  20. savePath=/dw/recommend/model/831_recsys_analysis_data/
  21. /opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8/bin/spark-class2 org.apache.spark.deploy.SparkSubmit \
  22. --class com.aliyun.odps.spark.examples.makedata_recsys_r_rate.train_feature_stat \
  23. --master yarn --driver-memory 2G --executor-memory 4G --executor-cores 1 --num-executors 24 \
  24. /mnt/disk1/jch/recommend-emr-dataprocess/target/spark-examples-1.0.0-SNAPSHOT-jar-with-dependencies.jar \
  25. readPath:${readPath} \
  26. beginStr:${start_date} endStr:${end_date} \
  27. repartition:1 \
  28. savePath:${savePath}