diff --git a/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java b/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java index 6815827353..93f07f1b32 100644 --- a/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java +++ b/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java @@ -107,13 +107,13 @@ public class HashPartitionServiceTest { map.put(partition, map.getOrDefault(partition, 0) + 1); } - printDispersion(start, map); + printDispersion(start, map, ITERATIONS); } @Test public void testDispersionOnResolveByPartitionIdx() { int serverCount = 10; - int queueCount = 1000; + int queueCount = 10000; int partitionCount = 3; List services = new ArrayList<>(); @@ -135,14 +135,14 @@ public class HashPartitionServiceTest { } } - printDispersion(start, map); + printDispersion(start, map, queueCount * partitionCount); } - private void printDispersion(long start, Map map) { + private void printDispersion(long start, Map map, int iterations) { List> data = map.entrySet().stream().sorted(Comparator.comparingInt(Map.Entry::getValue)).collect(Collectors.toList()); long end = System.currentTimeMillis(); double diff = (data.get(data.size() - 1).getValue() - data.get(0).getValue()); - double diffPercent = (diff / ITERATIONS) * 100.0; + double diffPercent = (diff / iterations) * 100.0; System.out.println("Time: " + (end - start) + " Diff: " + diff + "(" + String.format("%f", diffPercent) + "%)"); Assert.assertTrue(diffPercent < 0.5); for (Map.Entry entry : data) {