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