This is an automated email from the ASF dual-hosted git repository.
yong pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 003f3ed Pass envirnoment variables to the docker container when
building whee… (#10043)
new 05e1ccd [PIP-60] Add TLS SNI support for cpp and python clients
(#8957)
new 5a2f9ea [Tiered Storage] Prevent Class Loader Leak; Restore Offloader
Directory Override (#9878)
new 8ac9cfb [Messaging] Fix delay message block (#10078)
new 43c529f Avoid spammy logs in case of BK problems (#10088)
new bb41022 Fix AutoConsumeSchema KeyValue encoding (#10089)
new 0b3e510 Fix: seemingly equal ClientConfigurationData's objects end up
not being equal (#10091)
new f3b5ff7 Fix 8115 Some partitions get stuck after adding additional
consumers to the KEY_SHARED subscriptions (#10096)
new bc4cb4c Fix MessagePublishBufferThrottleTest flaky-test (#8733)
new 38fae22 [flaky test] Fix unit tests that occasionally fail (#9226)
new a0c9b6a Upgrade Jetty libraries to 9.4.39.v20210325 (#10177)
The 10 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:
distribution/server/src/assemble/LICENSE.bin.txt | 34 +++---
.../bookkeeper/mledger/offload/OffloaderUtils.java | 4 +-
.../mledger/offload/OffloadersCache.java | 68 +++++++++++
.../mledger/offload/OffloadersCacheTest.java | 62 ++++++++++
pom.xml | 2 +-
.../org/apache/pulsar/broker/PulsarService.java | 13 ++-
.../delayed/InMemoryDelayedDeliveryTracker.java | 9 +-
.../apache/pulsar/broker/service/ServerCnx.java | 4 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 15 ++-
.../broker/admin/IncrementPartitionsTest.java | 13 ++-
.../pulsar/broker/admin/TopicMessageTTLTest.java | 1 +
.../pulsar/broker/admin/v1/V1_AdminApiTest2.java | 1 +
.../broker/service/ConsumedLedgersTrimTest.java | 7 +-
.../service/MessagePublishBufferThrottleTest.java | 8 +-
.../broker/service/ReplicatorRateLimiterTest.java | 3 +
.../pulsar/broker/service/ReplicatorTestBase.java | 129 +++++++++++++--------
.../service/persistent/TopicDuplicationTest.java | 28 ++---
pulsar-client-cpp/lib/ClientConnection.cc | 14 ++-
.../client/impl/conf/ClientConfigurationData.java | 2 +-
.../client/impl/schema/AutoConsumeSchema.java | 3 +-
.../impl/conf/ConfigurationDataUtilsTest.java | 12 ++
.../client/impl/schema/KeyValueSchemaTest.java | 9 ++
.../apache/pulsar/functions/utils/Exceptions.java | 12 ++
.../pulsar/functions/utils/ExceptionsTest.java | 27 +++++
pulsar-sql/presto-distribution/LICENSE | 14 +--
.../pulsar/sql/presto/PulsarConnectorCache.java | 11 +-
.../integration/messaging/DelayMessagingTest.java | 105 +++++++++++++++++
.../src/test/resources/pulsar-messaging.xml | 4 +-
28 files changed, 492 insertions(+), 122 deletions(-)
create mode 100644
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloadersCache.java
create mode 100644
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/offload/OffloadersCacheTest.java
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/messaging/DelayMessagingTest.java
