@@ -56,7 +56,7 @@ public class RedisService implements Serializable {
String value = JSONUtils.toJson(record);
batch.put(redisKey, value);
- if (batch.size() >= 1000) {
+ if (batch.size() >= 500) {
mSet(jedis, batch, expire, TimeUnit.SECONDS);
batch.clear();
try {