This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 3d863ae35a6 [fix] PulsarLedgerManager: add missed return statement
(#16607)
new cbb060ec3e6 [fix][broker]Fix getInternalStats occasional lack of
LeaderInfo again (#16238)
new f8ac8ec0df5 [fix][flaky-test]
MessageTTLTest.testMessageExpiryAfterTopicUnload (#16462)
new daeb418afff [fix][broker] Expose timestamp field for
SchemaData&SchemaInfo (#16380)
new 4868463818a [fix][test] Fix jvm oom on Unit Test broker group 1
(#16542)
new 1eab46fb582 [fix][test] Catch exception when update data in
mockZookeeper (#16473)
new 3fc367d52b5 [fix][flaky-test]
PersistentFailoverE2ETest.testSimpleConsumerEventsWithPartition (#16493)
new 8eb11ef1aad [improve][test] Reduce the time consumption of
BacklogQuotaManagerTest (#16550)
new 9fc54308781 Fix flaky-test: NonPersistentTopicE2ETest.testGC (#16505)
new 0a507cea6f5 [improve][test] Fix flaky C++ ClientTest.testWrongListener
(#16510)
new 66e18626a8a [fix][broker] Retry when DistributedIdGenerator has
BadVersion error (#16491)
new 379506284d7 [fix][flaky-test] Fix flaky test
testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#16419)
new b9504f460d9 [fix][broker] Skip reading more entries for a pending read
with no more entries (#16400)
new b040c45af15 [improve][metadataStore] Update namespace policies would
cause metadata-store thread waiting too long (#16438)
new de54ef6791d Fix: Make DeadLetterPolicy deserializable (#16513)
new 0d2a25412a9 [fix][pulsar-broker] Fix RawReader hasMessageAvailable
returns true when no messages (#16443)
The 15 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:
.../bookkeeper/mledger/ManagedLedgerException.java | 7 +
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 3 +-
.../pulsar/broker/service/BrokerService.java | 6 +-
.../PersistentDispatcherSingleActiveConsumer.java | 8 +
.../broker/service/persistent/PersistentTopic.java | 76 +++++-----
.../service/schema/SchemaRegistryServiceImpl.java | 1 +
.../apache/pulsar/client/impl/RawReaderImpl.java | 3 +
.../pulsar/broker/admin/AdminApiSchemaTest.java | 18 ++-
.../broker/admin/AdminApiSchemaWithAuthTest.java | 21 +--
.../broker/service/BacklogQuotaManagerTest.java | 62 +++++---
.../pulsar/broker/service/MessageTTLTest.java | 33 +++--
.../broker/service/NonPersistentTopicE2ETest.java | 4 +-
.../broker/service/PersistentFailoverE2ETest.java | 31 ++--
.../pulsar/client/api/DeadLetterTopicTest.java | 29 +++-
.../pulsar/client/api/MultiTopicsConsumerTest.java | 32 ++--
.../apache/pulsar/client/api/SimpleSchemaTest.java | 44 +++---
.../apache/pulsar/client/impl/RawReaderTest.java | 52 +++++++
.../java/org/apache/pulsar/schema/SchemaTest.java | 9 +-
.../pulsar/client/admin/internal/SchemasImpl.java | 1 +
.../apache/pulsar/client/api/DeadLetterPolicy.java | 4 +
.../PulsarClientImplementationBinding.java | 3 +-
.../apache/pulsar/common/schema/SchemaInfo.java | 13 +-
pulsar-client-cpp/lib/ClientImpl.cc | 4 +-
pulsar-client-cpp/tests/ClientTest.cc | 8 +-
.../PulsarClientImplementationBindingImpl.java | 6 +-
.../impl/schema/RecordSchemaBuilderImpl.java | 1 +
.../pulsar/client/impl/schema/SchemaInfoTest.java | 15 +-
.../pulsar/client/impl/schema/SchemaInfoImpl.java | 5 +
.../api/coordination/CoordinationService.java | 4 +
.../coordination/impl/CoordinationServiceImpl.java | 32 ++++
.../org/apache/pulsar/metadata/CounterTest.java | 64 +++++++-
.../java/org/apache/zookeeper/MockZooKeeper.java | 161 ++++++++++++---------
32 files changed, 526 insertions(+), 234 deletions(-)
