[GitHub] [rocketmq-streams] starmilkxin opened a new issue, #290: The logic of watermark judging whether to solve the data may result in missing data.

Sat, 13 May 2023 06:43:57 -0700 


starmilkxin opened a new issue, #290:
URL: https://github.com/apache/rocketmq-streams/issues/290

   
![image](https://github.com/apache/rocketmq-streams/assets/55646681/e5845435-17b5-4429-b35b-65699d93e7cc)
   
   ```java
     long time = this.context.getDataTime();
   
     long watermark = this.watermark(time - allowDelay, stateTopicMessageQueue);
     if (time < watermark) {
         //已经触发，丢弃数据
         logger.warn("discard data:[{}], window has been fired. time of 
data:{}, watermark:{}",
                 data, time, watermark);
         return;
     }
   ```
   
   It is expected that the dataA should be included in the time window, but the 
current logic is to discard it directly.
   
   Should it be based on the end time of the time window?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to