#Updates#redis写入插件升级，先删除老key数据，再写入数据

phillip2019 · Aug 18, 2024 · df5e369 · df5e369
1 parent 92bcb11
commit df5e369
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...swriter/src/main/java/com/alibaba/datax/plugin/writer/rediswriter/RedisWriteAbstract.java b/...swriter/src/main/java/com/alibaba/datax/plugin/writer/rediswriter/RedisWriteAbstract.java
@@ -153,7 +153,7 @@ public void deleteOldData() {
      */
     public void syncData() {
         // 若数据大于0，开始写入同步数据
-        if (records > batchSize) {
+        if (records >= batchSize) {
             RedisWriterHelper.syncData(pipelined);
             records = 0;
         }