|
|
@@ -111,8 +111,8 @@ public class ODPSToRedis {
|
|
|
}
|
|
|
|
|
|
log.info("odps count {}", count);
|
|
|
- long odpsBatchSize = NumberUtils.toLong(argMap.getOrDefault("odpsBatchSize", "200000"));
|
|
|
if (!argMap.containsKey("partitionNum")){
|
|
|
+ long odpsBatchSize = NumberUtils.toLong(argMap.getOrDefault("odpsBatchSize", "200000"));
|
|
|
argMap.put("partitionNum", String.valueOf(count / odpsBatchSize + 1));
|
|
|
}
|
|
|
|