Pārlūkot izejas kodu

feat:修改补数据脚本

zhaohaipeng 1 mēnesi atpakaļ
vecāks
revīzija
a815ef3502
1 mainītis faili ar 2 papildinājumiem un 10 dzēšanām
  1. 2 10
      recommend/00_train_data_make.sh

+ 2 - 10
recommend/00_train_data_make.sh

@@ -9,7 +9,7 @@ for dt in "${dts[@]}"; do
     --class com.aliyun.odps.spark.examples.makedata_recsys.v20250218.makedata_recsys_41_originData_20250218 \
     --master yarn --driver-memory 1G --executor-memory 2G --executor-cores 1 --num-executors 10 \
     /root/zhaohp/recommend-emr-dataprocess/target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
-    tablePart:64 beginStr:${dt}00 endStr:${dt}11 repartition:32 \
+    tablePart:64 beginStr:${dt}00 endStr:${dt}15 repartition:32 \
     savePath:/dw/recommend/model/41_recsys_origin_date \
     table:dwd_recsys_alg_sample_all_20250212 &
 
@@ -17,15 +17,7 @@ for dt in "${dts[@]}"; do
     --class com.aliyun.odps.spark.examples.makedata_recsys.v20250218.makedata_recsys_41_originData_20250218 \
     --master yarn --driver-memory 1G --executor-memory 2G --executor-cores 1 --num-executors 10 \
     /root/zhaohp/recommend-emr-dataprocess/target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
-    tablePart:64 beginStr:${dt}12 endStr:${dt}17 repartition:32 \
-    savePath:/dw/recommend/model/41_recsys_origin_date \
-    table:dwd_recsys_alg_sample_all_20250212 &
-
-    /opt/apps/SPARK2/spark-2.4.8-hadoop3.2-1.0.8/bin/spark-class2 org.apache.spark.deploy.SparkSubmit \
-    --class com.aliyun.odps.spark.examples.makedata_recsys.v20250218.makedata_recsys_41_originData_20250218 \
-    --master yarn --driver-memory 1G --executor-memory 2G --executor-cores 1 --num-executors 10 \
-    /root/zhaohp/recommend-emr-dataprocess/target/spark-examples-1.0.0-SNAPSHOT-shaded.jar \
-    tablePart:64 beginStr:${dt}18 endStr:${dt}23 repartition:32 \
+    tablePart:64 beginStr:${dt}16 endStr:${dt}23 repartition:32 \
     savePath:/dw/recommend/model/41_recsys_origin_date \
     table:dwd_recsys_alg_sample_all_20250212 &