临时记录的脚本 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. 【新 上游样本】
  2. nohup /opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8/bin/spark-class2 org.apache.spark.deploy.SparkSubmit \
  3. --class com.aliyun.odps.spark.examples.makedata.makedata_10_originData_v3 \
  4. --master yarn --driver-memory 1G --executor-memory 1G --executor-cores 1 --num-executors 64 \
  5. ./target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
  6. tablePart:64 savePath:/dw/recommend/model/10_sample_data_v3/ beginStr:20240227 endStr:20240227 > p10_.log 2>&1 &
  7. [ros样本生产]
  8. nohup /opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8/bin/spark-class2 org.apache.spark.deploy.SparkSubmit \
  9. --class com.aliyun.odps.spark.examples.makedata.makedata_12_rosData_v3 \
  10. --master yarn --driver-memory 1G --executor-memory 1G --executor-cores 1 --num-executors 32 \
  11. ./target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
  12. savePath:/dw/recommend/model/12_ros_data_v3/ beginStr:20240228 endStr:20240228 ifRepart:10 \
  13. > p12_1.log 2>&1 &
  14. nohup /opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8/bin/spark-class2 org.apache.spark.deploy.SparkSubmit \
  15. --class com.aliyun.odps.spark.examples.makedata.makedata_12_rosData_v3_noweight \
  16. --master yarn --driver-memory 1G --executor-memory 1G --executor-cores 1 --num-executors 32 \
  17. ./target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
  18. savePath:/dw/recommend/model/12_ros_data_v3_noweight/ beginStr:20240222 endStr:20240226 ifRepart:10 \
  19. > p12_2.log 2>&1 &
  20. [str样本生产]
  21. nohup /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.makedata_11_strData_v3 \
  23. --master yarn --driver-memory 1G --executor-memory 1G --executor-cores 1 --num-executors 64 \
  24. ./target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
  25. savePath:/dw/recommend/model/11_str_data_v3/ beginStr:20240227 endStr:20240227 ifRepart:100 \
  26. > p11.log 2>&1 &
  27. [user写redis]
  28. nohup /opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8/bin/spark-class2 org.apache.spark.deploy.SparkSubmit \
  29. --class com.aliyun.odps.spark.examples.makedata.makedata_09_user2redis_freq \
  30. --name makedata_09_user2redis_freq \
  31. --master yarn --driver-memory 1G --executor-memory 4G --executor-cores 1 --num-executors 32 \
  32. --conf spark.yarn.executor.memoryoverhead=1024 \
  33. /root/zhangbo/recommend-emr-dataprocess/target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
  34. date:20240302 tablePart:96 expireDay:3 ifWriteRedisUser:True ifUser:True midDays:14 redisLimit:80000000 \
  35. savePathUser:/dw/recommend/model/09_feature/user/ > p09.log 2>&1 &
  36. --------------
  37. 【旧STR 上游样本】
  38. nohup /opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8/bin/spark-class2 org.apache.spark.deploy.SparkSubmit \
  39. --class com.aliyun.odps.spark.examples.makedata.makedata_06_originData \
  40. --master yarn --driver-memory 1G --executor-memory 2G --executor-cores 1 --num-executors 32 \
  41. --conf spark.yarn.executor.memoryoverhead=1024 \
  42. --conf spark.shuffle.service.enabled=true \
  43. --conf spark.shuffle.service.port=7337 \
  44. --conf spark.shuffle.consolidateFiles=true \
  45. --conf spark.shuffle.manager=sort \
  46. --conf spark.storage.memoryFraction=0.4 \
  47. --conf spark.shuffle.memoryFraction=0.5 \
  48. --conf spark.default.parallelism=200 \
  49. ./target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
  50. tablePart:64 savePath:/dw/recommend/model/00_sample_data/ beginStr:20240311 endStr:20240312 > p6.log 2>&1 &
  51. 【旧STR 训练数据】
  52. nohup /opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8/bin/spark-class2 org.apache.spark.deploy.SparkSubmit \
  53. --class com.aliyun.odps.spark.examples.makedata.makedata_07_strData \
  54. --master yarn --driver-memory 1G --executor-memory 1G --executor-cores 1 --num-executors 32 \
  55. ./target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
  56. savePath:/dw/recommend/model/04_str_data/ beginStr:20240311 endStr:20240312 featureVersion:v4 ifRepart:100 \
  57. > p7.log 2>&1 &