You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tubemq.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2021/03/01 09:08:00 UTC
[jira] [Commented] (TUBEMQ-555) short session data can only be
written to a specific partition
[ 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: 曹显乐 <xi...@vivo.com>
Co-authored-by: gosonzhang <go...@tencent.com>
Co-authored-by: 曹显乐 <xi...@vivo.com>
> 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)