|
|
@@ -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.001) {
|
|
|
+ if (RandomUtils.nextDouble() <= 0.0001) {
|
|
|
log.info("redisKey: {}, value: {}", redisKey, value);
|
|
|
}
|
|
|
batch.put(redisKey, value);
|