丁云鹏 hace 11 meses
padre
commit
c9d1358b24

+ 2 - 2
recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/ODPSToRedis.java

@@ -41,14 +41,14 @@ public class ODPSToRedis {
         DTSConfig config = dtsConfigService.getDTSConfig(argMap);
         if (config == null || !config.selfCheck()) {
             log.error("dts config error");
-            System.exit(0);
+            return;
         }
 
         List<Map<String, String>> fieldValues = odpsService.read(config, argMap);
         log.info("odps count {}", fieldValues.size());
         if (CollectionUtils.isEmpty(fieldValues)) {
             log.info("odps empty");
-            System.exit(0);
+            return;
         }
 
         // RDD