[jira] [Updated] (ROCKETMQ-275) The comment of PushConsumer’s configuration “unitMode” is ambiguous
[ https://issues.apache.org/jira/browse/ROCKETMQ-275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yukon updated ROCKETMQ-275: --- Priority: Minor (was: Major) > The comment of PushConsumer’s configuration “unitMode” is ambiguous > --- > > Key: ROCKETMQ-275 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-275 > Project: Apache RocketMQ > Issue Type: Improvement > Components: rocketmq-client >Reporter: Mark Yang >Assignee: Xiaorui Wang >Priority: Minor > > The code in DefaultMQPushConsumer.java >/** > * Whether the unit of subscription group > */ > private boolean unitMode = false; > - > What “unitMode” really mean, How do we use it ? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ROCKETMQ-275) The comment of PushConsumer’s configuration “unitMode” is ambiguous
[ https://issues.apache.org/jira/browse/ROCKETMQ-275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153784#comment-16153784 ] yukon commented on ROCKETMQ-275: Hi, since it's just a question, could you please use our mailing list? please refer to: http://rocketmq.apache.org/about/contact/ > The comment of PushConsumer’s configuration “unitMode” is ambiguous > --- > > Key: ROCKETMQ-275 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-275 > Project: Apache RocketMQ > Issue Type: Improvement > Components: rocketmq-client >Reporter: Mark Yang >Assignee: Xiaorui Wang > > The code in DefaultMQPushConsumer.java >/** > * Whether the unit of subscription group > */ > private boolean unitMode = false; > - > What “unitMode” really mean, How do we use it ? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (ROCKETMQ-275) The comment of PushConsumer’s configuration “unitMode” is ambiguous
[ https://issues.apache.org/jira/browse/ROCKETMQ-275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yukon updated ROCKETMQ-275: --- Issue Type: Improvement (was: Bug) > The comment of PushConsumer’s configuration “unitMode” is ambiguous > --- > > Key: ROCKETMQ-275 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-275 > Project: Apache RocketMQ > Issue Type: Improvement > Components: rocketmq-client >Reporter: Mark Yang >Assignee: Xiaorui Wang > > The code in DefaultMQPushConsumer.java >/** > * Whether the unit of subscription group > */ > private boolean unitMode = false; > - > What “unitMode” really mean, How do we use it ? -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (ROCKETMQ-276) rocketmq-spark
[ https://issues.apache.org/jira/browse/ROCKETMQ-276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yukon updated ROCKETMQ-276: --- Fix Version/s: (was: 4.1.0-incubating) > rocketmq-spark > --- > > Key: ROCKETMQ-276 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-276 > Project: Apache RocketMQ > Issue Type: Bug > Components: rocketmq-externals >Affects Versions: 4.1.0-incubating >Reporter: weiqichx >Assignee: dongeforever > Labels: patch > Attachments: RocketMqRDD.scala > > Original Estimate: 4h > Remaining Estimate: 4h > > When Multiple-broker in queue running, appear Failed to get records for > rs-consumer after polling. > Cause: RocketMqRDDIterator hasNext used offsetRange sum all broker. however > the first broker doesn't has next MessageExt. but index is serial in next > function. > fixed patch in attachment. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (ROCKETMQ-277) get localhost throw java.net.UnknownHostException,when server hostname not in /etc/hosts
[ https://issues.apache.org/jira/browse/ROCKETMQ-277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yukon updated ROCKETMQ-277: --- Issue Type: Improvement (was: Bug) > get localhost throw java.net.UnknownHostException,when server hostname not > in /etc/hosts > - > > Key: ROCKETMQ-277 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-277 > Project: Apache RocketMQ > Issue Type: Improvement > Components: rocketmq-client, rocketmq-commons >Affects Versions: 4.0.0-incubating, 4.1.0-incubating >Reporter: yubaofu >Assignee: Xiaorui Wang > Fix For: 4.2.0-incubating > > > if server hostname not in /etc/hosts, > org.apache.rocketmq.common.MixAll#localhost throw UnknownHostException -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ROCKETMQ-276) rocketmq-spark
[ https://issues.apache.org/jira/browse/ROCKETMQ-276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153764#comment-16153764 ] yukon commented on ROCKETMQ-276: Hi, thanks for your report. Attach a patch isn't a good method, cloud you please submit a PR to https://github.com/apache/incubator-rocketmq-externals? And there is a doc can help you to submit your first PR: http://rocketmq.apache.org/docs/how-to-contribute/ > rocketmq-spark > --- > > Key: ROCKETMQ-276 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-276 > Project: Apache RocketMQ > Issue Type: Bug > Components: rocketmq-externals >Affects Versions: 4.1.0-incubating >Reporter: weiqichx >Assignee: dongeforever > Labels: patch > Fix For: 4.1.0-incubating > > Attachments: RocketMqRDD.scala > > Original Estimate: 4h > Remaining Estimate: 4h > > When Multiple-broker in queue running, appear Failed to get records for > rs-consumer after polling. > Cause: RocketMqRDDIterator hasNext used offsetRange sum all broker. however > the first broker doesn't has next MessageExt. but index is serial in next > function. > fixed patch in attachment. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ROCKETMQ-282) RocketMQ-GO-Client
[ https://issues.apache.org/jira/browse/ROCKETMQ-282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153742#comment-16153742 ] ASF GitHub Bot commented on ROCKETMQ-282: - Github user zhouxinyu commented on the issue: https://github.com/apache/incubator-rocketmq-externals/pull/28 cool~ Thanks @StyleTang > RocketMQ-GO-Client > -- > > Key: ROCKETMQ-282 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-282 > Project: Apache RocketMQ > Issue Type: Task > Components: rocketmq-client >Reporter: Jie.Tang >Assignee: Jie.Tang > > RocketMQ-GO-Client -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (ROCKETMQ-285) file test error when make link
[
https://issues.apache.org/jira/browse/ROCKETMQ-285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yukon updated ROCKETMQ-285:
---
Fix Version/s: 4.2.0-incubating
> file test error when make link
> --
>
> Key: ROCKETMQ-285
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-285
> Project: Apache RocketMQ
> Issue Type: Bug
> Components: build
>Affects Versions: 4.0.0-incubating, 4.1.0-incubating
>Reporter: willim.z
>Assignee: yukon
> Fix For: 4.2.0-incubating
>
>
> error file path: distribution/bin/os.sh.
> line 62.
> cannot test ${HOME}/tmpfs while making link to ./tmpfs
> change "ln -s /dev/shm tmpfs" to "ln -s /dev/shm ${HOME}/tmpfs"
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
[jira] [Assigned] (ROCKETMQ-285) file test error when make link
[
https://issues.apache.org/jira/browse/ROCKETMQ-285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yukon reassigned ROCKETMQ-285:
--
Assignee: yukon (was: Stevens Chew)
> file test error when make link
> --
>
> Key: ROCKETMQ-285
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-285
> Project: Apache RocketMQ
> Issue Type: Bug
> Components: build
>Affects Versions: 4.0.0-incubating, 4.1.0-incubating
>Reporter: willim.z
>Assignee: yukon
> Fix For: 4.2.0-incubating
>
>
> error file path: distribution/bin/os.sh.
> line 62.
> cannot test ${HOME}/tmpfs while making link to ./tmpfs
> change "ln -s /dev/shm tmpfs" to "ln -s /dev/shm ${HOME}/tmpfs"
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
[jira] [Commented] (ROCKETMQ-265) when os crash for some reasons, the broker consume queue’s data maybe repeat, consumer can’t pull the latest message, cause message lag
[ https://issues.apache.org/jira/browse/ROCKETMQ-265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153501#comment-16153501 ] ASF GitHub Bot commented on ROCKETMQ-265: - Github user coveralls commented on the issue: https://github.com/apache/incubator-rocketmq/pull/146 [](https://coveralls.io/builds/13127783) Coverage increased (+0.07%) to 38.77% when pulling **ecb01f7650e85bfbcdc7aa148711bf075aea958b on fuyou001:ROCKETMQ-265** into **6a97d2884fe8ea23de8f231c8647b99ea5be1811 on apache:develop**. > when os crash for some reasons, the broker consume queue’s data maybe repeat, > consumer can’t pull the latest message, cause message lag > --- > > Key: ROCKETMQ-265 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-265 > Project: Apache RocketMQ > Issue Type: Bug > Components: rocketmq-store >Affects Versions: 4.0.0-incubating, 4.1.0-incubating >Reporter: yubaofu >Assignee: yukon >Priority: Critical > Labels: bug > Fix For: 4.2.0-incubating > > Original Estimate: 24h > Remaining Estimate: 24h > > when os crash for some reasons, the broker consume queue’s data maybe repeat, > consumer can’t pull the latest message, cause message lag -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (ROCKETMQ-265) when os crash for some reasons, the broker consume queue’s data maybe repeat, consumer can’t pull the latest message, cause message lag
[ https://issues.apache.org/jira/browse/ROCKETMQ-265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153408#comment-16153408 ] ASF GitHub Bot commented on ROCKETMQ-265: - Github user coveralls commented on the issue: https://github.com/apache/incubator-rocketmq/pull/146 [](https://coveralls.io/builds/13126602) Coverage increased (+0.08%) to 38.781% when pulling **7320a82136061ac6f1ca565ba98f047d05c18d5a on fuyou001:ROCKETMQ-265** into **6a97d2884fe8ea23de8f231c8647b99ea5be1811 on apache:develop**. > when os crash for some reasons, the broker consume queue’s data maybe repeat, > consumer can’t pull the latest message, cause message lag > --- > > Key: ROCKETMQ-265 > URL: https://issues.apache.org/jira/browse/ROCKETMQ-265 > Project: Apache RocketMQ > Issue Type: Bug > Components: rocketmq-store >Affects Versions: 4.0.0-incubating, 4.1.0-incubating >Reporter: yubaofu >Assignee: yukon >Priority: Critical > Labels: bug > Fix For: 4.2.0-incubating > > Original Estimate: 24h > Remaining Estimate: 24h > > when os crash for some reasons, the broker consume queue’s data maybe repeat, > consumer can’t pull the latest message, cause message lag -- This message was sent by Atlassian JIRA (v6.4.14#64029)
