[
https://issues.apache.org/jira/browse/TUBEMQ-555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281108#comment-17281108
]
ASF subversion and git services commented on TUBEMQ-555:
--------------------------------------------------------
Commit 0cce8d762f4148ecd138bf64553a55fc24ee565b in incubator-tubemq's branch
refs/heads/master from gosonzhang
[ https://gitbox.apache.org/repos/asf?p=incubator-tubemq.git;h=0cce8d7 ]
[TUBEMQ-555] short session data can only be written to a specific partition
(addendum) (#423)
Co-authored-by: 曹显乐 <[email protected]>
Co-authored-by: gosonzhang <[email protected]>
Co-authored-by: 曹显乐 <[email protected]>
> short session data can only be written to a specific partition
> --------------------------------------------------------------
>
> Key: TUBEMQ-555
> URL: https://issues.apache.org/jira/browse/TUBEMQ-555
> Project: Apache TubeMQ
> Issue Type: Bug
> Components: Client
> Reporter: xianle cao
> Assignee: xianle cao
> Priority: Major
> Labels: pull-request-available
> Time Spent: 1.5h
> Remaining Estimate: 0h
>
> When a user uses a short session to write data, it starts from 0 each time,
> so the data can only be written to a fixed partition, which causes an
> imbalance problem.
> className:
> RoundRobinPartitionRouter.class
> code:
> ```
> AtomicInteger newCounter = new AtomicInteger(0);
> ```
> solution:
> ```
> AtomicInteger newCounter = new AtomicInteger(new Random().nextInt());
> ```
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
