diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java
index 74c86e4e8..d5a1bcd5b 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java
@@ -75,9 +75,9 @@ public class ElasticSearchBatchSyncListener {
                     if (support(event)) {
                         String processInstanceId = event.normalizedData(String.class);
                         idSet.add(processInstanceId);
-                        log.info("batch sync es processIds: {}", processInstanceId);
                     }
                 }
+                log.warn("deduplication ids size: {}", idSet.size());
                 idSet.forEach(this::sync);
             } catch (Exception e) {
                 return ConsumeConcurrentlyStatus.RECONSUME_LATER;