You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe the bug
A single pulsar broker should only compact a single partition at a time. Otherwise the memory usage of compacting multiple partitions in parallel increases the chance of OutOfMemoryErrors
To Reproduce
Steps to reproduce the behavior:
Create a topic with many partitions
Publish lots of data to all of the partitions
Use pulsar admin to establish compaction thresholds that would trigger compaction for the partitions published to above. bin/pulsar-admin namespaces set-compaction-threshold \ --threshold <some threshold> <tenant/namespace>
Check the logs. Notice how on one broker compaction is triggered for the same partition within the same second (in the screenshot, these logs are all for broker 1).
Expected behavior
Compaction should only run for 1 partition at a time on a given broker. The source code would suggest to me this was the intended behaviour, but it doesn't appear to be working that way.
@lukestephenson I think we should add a throttling logic for people to define the parallelism for compaction. This would allow people to balance between the resource usage and the speed of compaction.
Describe the bug
A single pulsar broker should only compact a single partition at a time. Otherwise the memory usage of compacting multiple partitions in parallel increases the chance of OutOfMemoryErrors
To Reproduce
Steps to reproduce the behavior:
bin/pulsar-admin namespaces set-compaction-threshold \ --threshold <some threshold> <tenant/namespace>
Expected behavior
Compaction should only run for 1 partition at a time on a given broker. The source code would suggest to me this was the intended behaviour, but it doesn't appear to be working that way.
Screenshots
Attached logs
Additional context
Raised on slack initially. https://apache-pulsar.slack.com/archives/C5Z4T36F7/p1591243377186900
Pulsar version: 2.5.2
The text was updated successfully, but these errors were encountered: