|
@@ -76,7 +76,7 @@ public class FeatureDiff {
|
|
|
String table = "alg_recsys_sample_all_new";
|
|
|
String partition = "dt=" + args[1] + ",hh=" + args[2];
|
|
|
|
|
|
- int partitionNum = Integer.valueOf(args[3]);
|
|
|
+ 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");
|