Fix HashPartitionServiceTest

1 year ago · faf4a2165f
1 changed files with 1 additions and 1 deletions
--- a/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java
+++ b/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java
@ -436,7 +436,7 @@ public class HashPartitionServiceTest {
        ReflectionTestUtils.setField(partitionService, "edgeTopic", "tb.edge");
        ReflectionTestUtils.setField(partitionService, "edgePartitions", 10);
        ReflectionTestUtils.setField(partitionService, "edqsPartitions", 12);
-        ReflectionTestUtils.setField(partitionService, "tasksPartitions", 12);
+        ReflectionTestUtils.setField(partitionService, "defaultTasksPartitions", 12);
        partitionService.init();
        partitionService.partitionsInit();
        return partitionService;