iamqq23ue commented on pull request #2707: URL: https://github.com/apache/rocketmq/pull/2707#issuecomment-876090169
> > > Good catch! But I feel that the change is a bit complicated. When the flushing error occurs, the location flushedPosition does not move and will return to the client FLUSH_DISK_TIMEOUT. > > > > > > **this.flushedPosition.set(value);** > > You can see that this line of code will be executed no matter what。So even if an error is reported, the position will change。 > > You're right. But when an exception is thrown, we can not set flushedPosition. 请问什么时候可以修复这个bug呢，目前想考虑多个单master组成集群的架构，主要困难就是这个bug可能导致数据丢失。 -- 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]
