调整设置 mapedFileSizeConsumeQueue 是为了方便测试,4.2版本默认的是600W

2018-03-14 0:00 GMT+08:00 智齿 <jarvisb...@foxmail.com>:

>
> 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"<zhange...@gmail.com>;
> *发送时间:* 2018年3月13日(星期二) 下午2:43
> *收件人:* "users"<users@rocketmq.apache.org>;
> *主题:* 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]
>
>
>

Reply via email to