特征验证

recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/FeatureDiff.java

@@ -66,7 +66,7 @@ public class FeatureDiff {
         String table = "alg_recsys_sample_all_new";
         String partition = "dt=20240616,hh=10";
 
-        int partitionNum = 1;
+        int partitionNum = Integer.valueOf(args[0]);
         JavaRDD<Map<String, String>> fieldValues = odpsService.read(jsc, project, table, partition, partitionNum);
         if (fieldValues == null) {
             log.info("odps empty");