[
https://issues.apache.org/jira/browse/STORM-1231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15148209#comment-15148209
]
Xin Wang edited comment on STORM-1231 at 2/16/16 7:40 AM:
----------------------------------------------------------
PR(https://github.com/apache/storm/pull/1108) ported
`backtype.storm.scheduler.EvenScheduler` to java,
and fixed the load balancing issue.
load balancing issue:
We have a 3 nodes(supervisor1,supervisor2,supervisor3) cluster, each node has 3
available slots. And we submit two topolopies, the first has 2 workers and the
second has 4 workers.
total available slots:[supervisor1:6700, supervisor2:6700, supervisor3:6700,
supervisor1:6701, supervisor2:6701, supervisor3:6701, supervisor1:6702,
supervisor2:6702, supervisor3:6702]
*before fix*
first assign:[supervisor1:6700, supervisor2:6700]
current available slots:[supervisor1:6701, supervisor2:6701, supervisor3:6700,
supervisor1:6702, supervisor2:6702, supervisor3:6701, supervisor3:6702]
second assign:[supervisor1:6701, supervisor2:6701, supervisor3:6700,
supervisor1:6702]
*after fix:*
first assign:[supervisor1:6700, supervisor2:6700]
current available slots:[supervisor3:6700, supervisor1:6701, supervisor2:6701,
supervisor3:6701, supervisor1:6702, supervisor2:6702, supervisor3:6702]
second assign:[supervisor3:6700, supervisor1:6701, supervisor2:6701,
supervisor3:6701]
was (Author: vesense):
PR(https://github.com/apache/storm/pull/1108) ported
{code}backtype.storm.scheduler.EvenScheduler{code} to java,
and fixed the load balancing issue.
load balancing issue:
We have a 3 nodes(supervisor1,supervisor2,supervisor3) cluster, each node has 3
available slots. And we submit two topolopies, the first has 2 workers and the
second has 4 workers.
total available slots:[supervisor1:6700, supervisor2:6700, supervisor3:6700,
supervisor1:6701, supervisor2:6701, supervisor3:6701, supervisor1:6702,
supervisor2:6702, supervisor3:6702]
*before fix*
first assign:[supervisor1:6700, supervisor2:6700]
current available slots:[supervisor1:6701, supervisor2:6701, supervisor3:6700,
supervisor1:6702, supervisor2:6702, supervisor3:6701, supervisor3:6702]
second assign:[supervisor1:6701, supervisor2:6701, supervisor3:6700,
supervisor1:6702]
*after fix:*
first assign:[supervisor1:6700, supervisor2:6700]
current available slots:[supervisor3:6700, supervisor1:6701, supervisor2:6701,
supervisor3:6701, supervisor1:6702, supervisor2:6702, supervisor3:6702]
second assign:[supervisor3:6700, supervisor1:6701, supervisor2:6701,
supervisor3:6701]
> port backtype.storm.scheduler.EvenScheduler to java
> ---------------------------------------------------
>
> Key: STORM-1231
> URL: https://issues.apache.org/jira/browse/STORM-1231
> Project: Apache Storm
> Issue Type: New Feature
> Reporter: Robert Joseph Evans
> Assignee: Xin Wang
> Labels: java-migration, jstorm-merger
>
> Port the even scheduler to java.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
