This is an automated email from the ASF dual-hosted git repository.
rgao pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 9ad4ef2 [branch-2.9] [tests] Pulsar IO - Elasticsearch - reduce
elastic container memory usage and clean up test cases (#14631)
new 7061723 [ Issue 13551 ] FIxed NPE when reset-cursor at a non-existent
topic (RestException without cause) (#13573)
new 5a03b36 [Flaky-test]: Fix
MLTransactionMetadataStoreTest.testInitTransactionReader fails sporadically
(#14532)
new e1bcb2b [Flaky-test]: AdminApiTest.testNamespaceSplitBundleConcurrent
(#14565)
new 3dd8102 [C++] Fix wrong unit of Access Token Response's `expires_in`
field (#14554)
new 3a7640d [Broker] Fixed wrong behaviour caused by not cleaning up
topic policy service state. (#14503)
new a5612df [C++] Fix thread safety issue for multi topic consumer
(#14380)
The 6 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:
.../broker/admin/impl/PersistentTopicsBase.java | 2 +-
.../SystemTopicBasedTopicPoliciesService.java | 39 ++---
.../apache/pulsar/broker/web/RestException.java | 5 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 7 +-
.../pulsar/broker/admin/PersistentTopicsTest.java | 19 +++
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.cc | 166 +++++++++------------
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.h | 5 +-
pulsar-client-cpp/lib/SynchronizedHashMap.h | 127 ++++++++++++++++
pulsar-client-cpp/lib/auth/AuthOauth2.cc | 15 +-
pulsar-client-cpp/lib/auth/AuthOauth2.h | 5 +-
pulsar-client-cpp/tests/ConsumerTest.cc | 13 +-
pulsar-client-cpp/tests/SynchronizedHashMapTest.cc | 125 ++++++++++++++++
.../impl/MLTransactionMetadataStore.java | 1 +
13 files changed, 388 insertions(+), 141 deletions(-)
create mode 100644 pulsar-client-cpp/lib/SynchronizedHashMap.h
create mode 100644 pulsar-client-cpp/tests/SynchronizedHashMapTest.cc
