|
@@ -36,6 +36,7 @@ public class ODPSToRedis {
|
|
|
}
|
|
|
String env = argMap.get("env");
|
|
|
// ODPS
|
|
|
+ log.info("read odps");
|
|
|
DTSConfigService dtsConfigService = new DTSConfigService(env);
|
|
|
DTSConfig config = dtsConfigService.getDTSConfig(argMap);
|
|
|
if (config == null || !config.selfCheck()) {
|
|
@@ -43,7 +44,6 @@ public class ODPSToRedis {
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- log.info("read odps");
|
|
|
List<Map<String, String>> fieldValues = odpsService.read(config, argMap);
|
|
|
log.info("odps count {}", fieldValues.size());
|
|
|
if (CollectionUtils.isEmpty(fieldValues)) {
|