This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 8e77558211d [fix][fn] ack messages for window function when its result
is null (#23618)
new c73a29d1375 [fix][client] fix incomingMessageSize and client memory
usage is negative (#23624)
new fcd4436f320 [improve][broker] Reduce memory occupation of the delayed
message queue (#23611)
new e098c6bc513 [improve][broker] Skip unloading when bundle throughput is
zero (ExtensibleLoadManagerImpl only) (#23626)
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../delayed/InMemoryDelayedDeliveryTracker.java | 114 +++++++++++++++++----
.../loadbalance/extensions/models/TopKBundles.java | 6 ++
.../extensions/scheduler/TransferShedder.java | 10 ++
.../delayed/InMemoryDeliveryTrackerTest.java | 8 +-
.../extensions/models/TopKBundlesTest.java | 26 +++++
.../extensions/scheduler/TransferShedderTest.java | 20 ++++
.../client/api/SimpleProducerConsumerTest.java | 56 ++++++++++
.../impl/AutoScaledReceiverQueueSizeTest.java | 62 +++++++++++
.../apache/pulsar/client/impl/ConsumerBase.java | 5 +
.../apache/pulsar/client/impl/ConsumerImpl.java | 2 +
10 files changed, 287 insertions(+), 22 deletions(-)
