[INLONG-555] short session data can only be written to a specific partition

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.8.0
• Component/s: inlong-tubemq
• Labels: pull-request-available
• Assignee: xianle cao
• Reporter: xianle cao
• Created: 02/Feb/21 02:52
• Updated: 14/Sep/22 10:29
• Resolved: 11/Feb/21 03:58

Description

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());

```

Issue Links

• links to: GitHub Pull Request #421
• links to: GitHub Pull Request #423
• links to: GitHub Pull Request #556
• links to: GitHub Pull Request #1144