bxfjb commented on issue #8065:
URL: https://github.com/apache/rocketmq/issues/8065#issuecomment-2078832939

   > 分析的很具体,依次回复几个问题:
   > 
   > 1. 对于冷存储中的 CommitLog 可以从 0 开始,而 cq 必须与本地位点对齐,只能在 dispatch 
时才能确定初始化的位点,因此不会在 factory 中初始化指定,这一点也是为了保证与旧存储格式的兼容。
   > 2. fileSegment.getMaxTimestamp() != Long.MAX_VALUE 
这个条件还有一个原因是我发现之前同学实现的旧代码中有缺陷,没有修改 segment metadata 中的 time,导致整个 flatfile 无法过期删除。
   > 3. load 里面初始化的 destory 的间隔目前写的是1分钟,可以改为1小时。
   
   修改 destroy 间隔应该可以有效规避这个问题另外 2 提到的问题现在还存在吗,如果不存在的话是否可以去掉这个条件,因为按照 dispatch 
的逻辑,如果一个 FlatMessageFile存在


-- 
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