[
https://issues.apache.org/jira/browse/TUBEMQ-555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292748#comment-17292748
]
ASF subversion and git services commented on TUBEMQ-555:
--------------------------------------------------------
Commit cd21d8f1a58882cacaf63c8f8db3b2bcf387185a in incubator-tubemq's branch
refs/heads/TUBEMQ-469 from gosonzhang
[ https://gitbox.apache.org/repos/asf?p=incubator-tubemq.git;h=cd21d8f ]
[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
> Fix For: 0.8.0
>
> Time Spent: 1h 40m
> 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)
