Fix HashPartitionServiceTest.testPartitionChangeEvents_isolatedProfile_oneCommonServer_oneDedicated

3 years ago · fe8aaaa4d9
1 changed files with 0 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
@ -338,7 +338,6 @@ public class HashPartitionServiceTest {
                .setQueueName(isolatedQueue.getName())
                .build();
        partitionService_dedicated.removeQueue(queueDeleteMsg);
-        partitionService_dedicated.recalculatePartitions(dedicatedRuleEngine, List.of(commonRuleEngine));
        verifyPartitionChangeEvent(event -> {
            QueueKey queueKey = new QueueKey(ServiceType.TB_RULE_ENGINE, DataConstants.MAIN_QUEUE_NAME, tenantId);
            return event.getPartitionsMap().get(queueKey).isEmpty();