调整设置 mapedFileSizeConsumeQueue 是为了方便测试，4.2版本默认的是600W
2018-03-14 0:00 GMT+08:00 智齿 <[email protected]>: > > Hi, > > I have one doubt: [what] the set "mapedFileSizeConsumeQueue = 300000" is > with your meaning try to show? > Could you please tell us? > My friend. > > 祝好 > > > ------------------ 原始邮件 ------------------ > *发件人:* "el zhang"<[email protected]>; > *发送时间:* 2018年3月13日(星期二) 下午2:43 > *收件人:* "users"<[email protected]>; > *主题:* rocketmq-store 任务FlushConsumeQueueService 报错 > > hi，大家好 > 最近在使用rocketm发现 storeerror.log中有错误信息输出，请问 是不是配置上的不合理导致的 > 版本： 4.2.0 > 刷盘方式：异步刷盘 > mapedFileSizeConsumeQueue = 300000 > > org/apache/rocketmq/store/MappedFileQueue.java:478 > > broker的storeerror.log日志有如下错误， > > > 2018-03-12 15:16:36 WARN FlushConsumeQueueService - Offset for > /opt/rocketmq/store/consumequeue/xxx_xxxx_test/6/00000000000000000000 not > matched. Request offset: 300000, index: 1, mappedFileSize: 300000, > mappedFiles count: 1 2018-03-12 15:16:36 WARN FlushConsumeQueueService - > findMappedFileByOffset failure. java.lang.ArrayIndexOutOfBoundsException: > 1 at > java.util.concurrent.CopyOnWriteArrayList.get(CopyOnWriteArrayList.java:387) > ~[na:1.8.0_121] at java.util.concurrent.CopyOnWri > teArrayList.get(CopyOnWriteArrayList.java:396) ~[na:1.8.0_121] at > org.apache.rocketmq.store.MappedFileQueue.findMappedFileByOffset(MappedFileQueue.java:478) > [rocketmq-store-4.2.0.jar:4.2.0] at org.apache.rocketmq.store.Mapp > edFileQueue.flush(MappedFileQueue.java:427) [rocketmq-store-4.2.0.jar:4.2.0] > at org.apache.rocketmq.store.ConsumeQueue.flush(ConsumeQueue.java:324) > [rocketmq-store-4.2.0.jar:4.2.0] at org.apache.rocketmq.store.Defa > ultMessageStore$FlushConsumeQueueService.doFlush(DefaultMessageStore.java:1664) > [rocketmq-store-4.2.0.jar:4.2.0] at org.apache.rocketmq.store.Defa > ultMessageStore$FlushConsumeQueueService.run(DefaultMessageStore.java:1684) > [rocketmq-store-4.2.0.jar:4.2.0] at java.lang.Thread.run(Thread.java:745) > [na:1.8.0_121] > > >
