commit 7357c27cd2ebe39d04da7ff6deb3293024d5ef3f
author 维章 <nizeze.ni@alibaba-inc.com> Tue May 16 09:14:33 2023 +0800
committer 维章 <nizeze.ni@alibaba-inc.com> Tue May 16 09:14:33 2023 +0800
tree 5bff7bb6aae74e9082f05a330484549ad266fa14
parent db84168324b5f6965a7405f085764d7a64c718aa

modify the note

core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java

diff --git a/core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java b/core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java
index 7a0f5dc..b542923 100644
--- a/core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java
+++ b/core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java
@@ -206,7 +206,6 @@
 
             long watermark = this.watermark(time - allowDelay, stateTopicMessageQueue);
             if (time < watermark) {
-                //已经触发，丢弃数据
                 logger.warn("discard delay data:[{}]. time of data:{}, watermark:{}", data, time, watermark);
                 return;
             }