You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@distributedlog.apache.org by si...@apache.org on 2017/01/05 06:55:55 UTC

incubator-distributedlog git commit: DL-167: fix testCalculateUnequalWeight computing corner case

Repository: incubator-distributedlog
Updated Branches:
  refs/heads/master b44820b50 -> a31782093


DL-167: fix testCalculateUnequalWeight computing corner case

Author: xieliang <xi...@gmail.com>

Reviewers: Leigh Stewart <ls...@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 <xi...@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) {