Skip to content

Commit

Permalink
Merge pull request #24379 from mmaslankaprv/CORE-7157-fix-scaling-up-…
Browse files Browse the repository at this point in the history
…test

tests: made fast partition movement test a bit more tolerant
  • Loading branch information
mmaslankaprv authored Dec 2, 2024
2 parents 249eacc + b90e08c commit 722a101
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions tests/rptest/tests/scaling_up_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -475,14 +475,15 @@ def verify_disk_usage(usage: dict, added_ids: list, percentage: float):
for id in added_ids:
added_node_usage = usage[id]
assert added_node_usage < percentage * avg_usage, \
f"Added node {id} disk usage {added_node_usage} is too large, "
f"expected usage to be smaller than {percentage * avg_usage} bytes"
(f"Added node {id} disk usage {added_node_usage} is too large, "
f"expected usage to be smaller than {percentage * avg_usage} bytes")

usage = self._kafka_usage(nodes=self.redpanda.nodes[0:5])
print_disk_usage(usage)

verify_disk_usage(usage,
[self.redpanda.node_id(self.redpanda.nodes[4])], 0.3)
[self.redpanda.node_id(self.redpanda.nodes[4])],
0.35)

# add sixth node
self.redpanda.start_node(self.redpanda.nodes[5])
Expand All @@ -494,7 +495,7 @@ def verify_disk_usage(usage: dict, added_ids: list, percentage: float):
verify_disk_usage(usage, [
self.redpanda.node_id(self.redpanda.nodes[4]),
self.redpanda.node_id(self.redpanda.nodes[5])
], 0.3)
], 0.35)
# verify that data can be read
self.consumer = KgoVerifierSeqConsumer(self.test_context,
self.redpanda,
Expand Down

0 comments on commit 722a101

Please sign in to comment.