[jira] [Created] (ROCKETMQ-240) restart broker result in consumerOffset greater than brokerOffset

2017-07-06 Thread chen sun (JIRA) 
chen sun created ROCKETMQ-240:
-

 Summary: restart broker result in consumerOffset greater than 
brokerOffset
 Key: ROCKETMQ-240
 URL: https://issues.apache.org/jira/browse/ROCKETMQ-240
 Project: Apache RocketMQ
  Issue Type: Bug
  Components: rocketmq-broker, rocketmq-store
Affects Versions: 4.0.0-incubating
 Environment: centos 6.8 64bit , jdk1.7.50
Reporter: chen sun
Assignee: yukon
 Attachments: 111.png, 112.png

After the rocketmq restart, the monitoring console consumer delay is -13183, 
after viewing the details found that consumerOffset is greater than 
brokerOffset, and later led to news pulled tens of millions of historical 
messages re consumption. 13 of them were normal, and the other 5 were the 
problem.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

[jira] [Commented] (ROCKETMQ-239) Query message by time and get queue offset by time return is always less than want.

2017-07-06 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/ROCKETMQ-239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076077#comment-16076077
 ] 

ASF GitHub Bot commented on ROCKETMQ-239:
-

Github user coveralls commented on the issue:

https://github.com/apache/incubator-rocketmq/pull/129
  

[![Coverage 
Status](https://coveralls.io/builds/12271475/badge)](https://coveralls.io/builds/12271475)

Coverage increased (+0.3%) to 39.417% when pulling 
**c37adb566f7c0ee9920def4e9cfd02579e6ce4cf on 
lindzh:fix_query_message_by_time** into 
**d4149207e27ed3516f1f06407b55986790b806ae on apache:master**.



> Query message by time and get queue offset by time return is always less than 
> want. 
> 
>
> Key: ROCKETMQ-239
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-239
> Project: Apache RocketMQ
>  Issue Type: Bug
>  Components: rocketmq-store
>Affects Versions: 4.1.0-incubating
>Reporter: lindzh
>Assignee: yukon
> Fix For: 4.2.0-incubating
>
>
> When using queryMessageByTime or searchOffsetByTime or resetOffsetByTime , 
> DefaultMessageStore return offset is not so accurate as we want.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

[jira] [Commented] (ROCKETMQ-239) Query message by time and get queue offset by time return is always less than want.

2017-07-06 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/ROCKETMQ-239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076078#comment-16076078
 ] 

ASF GitHub Bot commented on ROCKETMQ-239:
-

Github user coveralls commented on the issue:

https://github.com/apache/incubator-rocketmq/pull/129
  

[![Coverage 
Status](https://coveralls.io/builds/12271475/badge)](https://coveralls.io/builds/12271475)

Coverage increased (+0.3%) to 39.417% when pulling 
**c37adb566f7c0ee9920def4e9cfd02579e6ce4cf on 
lindzh:fix_query_message_by_time** into 
**d4149207e27ed3516f1f06407b55986790b806ae on apache:master**.



> Query message by time and get queue offset by time return is always less than 
> want. 
> 
>
> Key: ROCKETMQ-239
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-239
> Project: Apache RocketMQ
>  Issue Type: Bug
>  Components: rocketmq-store
>Affects Versions: 4.1.0-incubating
>Reporter: lindzh
>Assignee: yukon
> Fix For: 4.2.0-incubating
>
>
> When using queryMessageByTime or searchOffsetByTime or resetOffsetByTime , 
> DefaultMessageStore return offset is not so accurate as we want.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

[jira] [Commented] (ROCKETMQ-239) Query message by time and get queue offset by time return is always less than want.

2017-07-06 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/ROCKETMQ-239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16076042#comment-16076042
 ] 

ASF GitHub Bot commented on ROCKETMQ-239:
-

GitHub user lindzh opened a pull request:

https://github.com/apache/incubator-rocketmq/pull/129

[ROCKETMQ-239]fix query message by time and fix get queue offset by time

When using queryMessageByTime or searchOffsetByTime or resetOffsetByTime , 
DefaultMessageStore return offset is not so accurate as we want.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/lindzh/incubator-rocketmq 
fix_query_message_by_time

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-rocketmq/pull/129.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #129


commit c37adb566f7c0ee9920def4e9cfd02579e6ce4cf
Author: lindzh 
Date:   2017-07-06T06:44:22Z

fix query message by time and fix get queue offset by time




> Query message by time and get queue offset by time return is always less than 
> want. 
> 
>
> Key: ROCKETMQ-239
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-239
> Project: Apache RocketMQ
>  Issue Type: Bug
>  Components: rocketmq-store
>Affects Versions: 4.1.0-incubating
>Reporter: lindzh
>Assignee: yukon
> Fix For: 4.2.0-incubating
>
>
> When using queryMessageByTime or searchOffsetByTime or resetOffsetByTime , 
> DefaultMessageStore return offset is not so accurate as we want.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

[jira] [Created] (ROCKETMQ-239) Query message by time and get queue offset by time return is always less than want.

2017-07-06 Thread lindzh (JIRA) 
lindzh created ROCKETMQ-239:
---

 Summary: Query message by time and get queue offset by time return 
is always less than want. 
 Key: ROCKETMQ-239
 URL: https://issues.apache.org/jira/browse/ROCKETMQ-239
 Project: Apache RocketMQ
  Issue Type: Bug
  Components: rocketmq-store
Affects Versions: 4.1.0-incubating
Reporter: lindzh
Assignee: yukon
 Fix For: 4.2.0-incubating


When using queryMessageByTime or searchOffsetByTime or resetOffsetByTime , 
DefaultMessageStore return offset is not so accurate as we want.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)