From b166597c8320e3a08597cbf000c0a50d931c6c0d Mon Sep 17 00:00:00 2001 From: chrislu Date: Sun, 28 Apr 2024 13:03:01 -0700 Subject: [PATCH] fix test --- weed/mq/pub_balancer/allocate_test.go | 1 - weed/mq/pub_balancer/balance_brokers_test.go | 2 -- 2 files changed, 3 deletions(-) diff --git a/weed/mq/pub_balancer/allocate_test.go b/weed/mq/pub_balancer/allocate_test.go index 3f1aa4fbf..7e7a09dab 100644 --- a/weed/mq/pub_balancer/allocate_test.go +++ b/weed/mq/pub_balancer/allocate_test.go @@ -12,7 +12,6 @@ func Test_allocateOneBroker(t *testing.T) { brokers := cmap.New[*BrokerStats]() brokers.SetIfAbsent("localhost:17777", &BrokerStats{ TopicPartitionCount: 0, - ConsumerCount: 0, CpuUsagePercent: 0, }) diff --git a/weed/mq/pub_balancer/balance_brokers_test.go b/weed/mq/pub_balancer/balance_brokers_test.go index 122984f0d..58731c24c 100644 --- a/weed/mq/pub_balancer/balance_brokers_test.go +++ b/weed/mq/pub_balancer/balance_brokers_test.go @@ -12,7 +12,6 @@ func TestBalanceTopicPartitionOnBrokers(t *testing.T) { brokers := cmap.New[*BrokerStats]() broker1Stats := &BrokerStats{ TopicPartitionCount: 1, - ConsumerCount: 1, CpuUsagePercent: 1, TopicPartitionStats: cmap.New[*TopicPartitionStats](), } @@ -24,7 +23,6 @@ func TestBalanceTopicPartitionOnBrokers(t *testing.T) { }) broker2Stats := &BrokerStats{ TopicPartitionCount: 2, - ConsumerCount: 1, CpuUsagePercent: 1, TopicPartitionStats: cmap.New[*TopicPartitionStats](), }