zhaohaipeng 2 часов назад
Родитель
Сommit
d02bf4a297

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

@@ -108,7 +108,6 @@ public class ODPSToRedis {
             log.info("odps empty");
             return;
         }
-        // log.info("odps count {}", fieldValues.count());
 
         // RDD
         log.info("sync redis");

+ 1 - 1
recommend-feature-produce/src/main/java/com/tzld/piaoquan/recommend/feature/produce/service/RedisService.java

@@ -48,7 +48,7 @@ public class RedisService implements Serializable {
             Map<String, String> record = dataIte.next();
             String redisKey = redisKey(record, config);
             String value = JSONUtils.toJson(record);
-            if (RandomUtils.nextDouble() <= 0.0001) {
+            if (RandomUtils.nextDouble() <= 0.001d) {
                 log.info("redisKey: {}, value: {}", redisKey, value);
             }
             batch.put(redisKey, value);