Repository: incubator-distributedlog Updated Branches: refs/heads/master b44820b50 -> a31782093
DL-167: fix testCalculateUnequalWeight computing corner case Author: xieliang <xieliang...@gmail.com> Reviewers: Leigh Stewart <lstew...@apache.org> Closes #94 from xieliang/DL-167-fix-testCalculateUnequalWeight Project: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/commit/a3178209 Tree: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/tree/a3178209 Diff: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/diff/a3178209 Branch: refs/heads/master Commit: a3178209350139af535203e1acff96a151b88013 Parents: b44820b Author: xieliang <xieliang...@gmail.com> Authored: Wed Jan 4 22:55:51 2017 -0800 Committer: Sijie Guo <si...@apache.org> Committed: Wed Jan 4 22:55:51 2017 -0800 ---------------------------------------------------------------------- .../service/placement/TestLeastLoadPlacementPolicy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/blob/a3178209/distributedlog-service/src/test/java/org/apache/distributedlog/service/placement/TestLeastLoadPlacementPolicy.java ---------------------------------------------------------------------- diff --git a/distributedlog-service/src/test/java/org/apache/distributedlog/service/placement/TestLeastLoadPlacementPolicy.java b/distributedlog-service/src/test/java/org/apache/distributedlog/service/placement/TestLeastLoadPlacementPolicy.java index 4f062f8..5f5ecd4 100644 --- a/distributedlog-service/src/test/java/org/apache/distributedlog/service/placement/TestLeastLoadPlacementPolicy.java +++ b/distributedlog-service/src/test/java/org/apache/distributedlog/service/placement/TestLeastLoadPlacementPolicy.java @@ -147,7 +147,7 @@ public class TestLeastLoadPlacementPolicy { assertTrue("Unexpected placement for " + numStreams + " streams to " + numSevers + " servers : highest load = " + highestLoadSeen + ", lowest load = " + lowestLoadSeen + ", max stream load = " + maxLoad.get(), - highestLoadSeen - lowestLoadSeen < maxLoad.get()); + highestLoadSeen - lowestLoadSeen <= maxLoad.get()); } private Set<SocketAddress> generateSocketAddresses(int num) {
