|
@@ -69,6 +69,7 @@ public class ODPSToRedis {
|
|
// TODO 报警
|
|
// TODO 报警
|
|
Map<String, String> partitionMap = odpsService.getLastestPartition(config, argMap);
|
|
Map<String, String> partitionMap = odpsService.getLastestPartition(config, argMap);
|
|
argMap.putAll(partitionMap);
|
|
argMap.putAll(partitionMap);
|
|
|
|
+ log.info("partitionMap {} argMap {}", JSONUtils.toJson(partitionMap), JSONUtils.toJson(argMap));
|
|
count = odpsService.count(config, argMap);
|
|
count = odpsService.count(config, argMap);
|
|
if (count <= 0) {
|
|
if (count <= 0) {
|
|
return;
|
|
return;
|