[GitHub] [incubator-inlong] dockerzhang opened a new issue #1144: [INLONG-555] short session data can only be written to a specific partition

[GitBox <gi...@apache.org>]

dockerzhang opened a new issue #1144:
URL: https://github.com/apache/incubator-inlong/issues/1144


   <p>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.</p>
   
   <p>className:</p>
   
   <p>RoundRobinPartitionRouter.class</p>
   
   <p>code:</p>
   
   <p>```</p>
   
   <p>AtomicInteger newCounter = new AtomicInteger(0);</p>
   
   <p>```</p>
   
   <p>solution:</p>
   
   <p>```</p>
   
   <p>AtomicInteger newCounter = new AtomicInteger(new Random().nextInt());</p>
   
   <p>```</p>
   <i>JIRA link - <a href="https://issues.apache.org/jira/browse/INLONG-555">[INLONG-555]</a> created by leno</i>


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [incubator-inlong] dockerzhang closed issue #1144: [INLONG-555] short session data can only be written to a specific partition

[GitBox <gi...@apache.org>]

dockerzhang closed issue #1144:
URL: https://github.com/apache/incubator-inlong/issues/1144


   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org