From de8da186a9b53a33a85ea9d35c7b597729c6e61d Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Thu, 21 Nov 2024 11:36:35 +0800
Subject: [PATCH] =?UTF-8?q?feat(REQ-3004)=20-=20=E4=BC=98=E5=8C=96=20ES=20?=
 =?UTF-8?q?=E5=90=8C=E6=AD=A5=E7=9A=84=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mq/inside/consumer/ElasticSearchBatchSyncListener.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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;