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