diff options
| author | chrislu <chris.lu@gmail.com> | 2024-04-28 13:03:01 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-04-28 13:03:01 -0700 |
| commit | b166597c8320e3a08597cbf000c0a50d931c6c0d (patch) | |
| tree | b99fe20ff4092cff0e7f97ed1b246577deef50ad | |
| parent | 189a7fc90e6fa866c6f158e7e5aa854681df864b (diff) | |
| download | seaweedfs-b166597c8320e3a08597cbf000c0a50d931c6c0d.tar.xz seaweedfs-b166597c8320e3a08597cbf000c0a50d931c6c0d.zip | |
fix test
| -rw-r--r-- | weed/mq/pub_balancer/allocate_test.go | 1 | ||||
| -rw-r--r-- | weed/mq/pub_balancer/balance_brokers_test.go | 2 |
2 files changed, 0 insertions, 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](), } |