This is an automated email from the ASF dual-hosted git repository. technoboy pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.2 by this push: new d43a640f1c9 [improve][broker] Clear thread local BrokerEntryMetadata instance before reuse (#22752) d43a640f1c9 is described below commit d43a640f1c9860662bba19f70a079d1db7066de5 Author: Lari Hotari <lhot...@users.noreply.github.com> AuthorDate: Wed May 22 05:56:14 2024 +0300 [improve][broker] Clear thread local BrokerEntryMetadata instance before reuse (#22752) --- .../src/main/java/org/apache/pulsar/common/protocol/Commands.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java index 65674af0ae1..8599ec2dd34 100644 --- a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java +++ b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java @@ -1705,6 +1705,7 @@ public class Commands { // | 2 bytes | 4 bytes | BROKER_ENTRY_METADATA_SIZE bytes | BrokerEntryMetadata brokerEntryMetadata = BROKER_ENTRY_METADATA.get(); + brokerEntryMetadata.clear(); for (BrokerEntryMetadataInterceptor interceptor : brokerInterceptors) { interceptor.intercept(brokerEntryMetadata); if (numberOfMessages >= 0) {