This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 2a0be4b Avoid call sync method in async rest API for force delete
subscription (#13668)
new d22798a [es-sink] Use topic name as the index name if indexName is
not configured (#13064)
new ebec861 Change ``ContextClassLoader`` to ``NarClassLoader`` in
BrokerInterceptor (#13589)
new 69e0499 [Security] Upgrade Jackson to 2.12.6 (#13694)
new b482256 [Security] Upgrade protobuf to 3.16.1 to address
CVE-2021-22569 (#13695)
new d3aa54f [pulsar-broker] The log prints
NamespaceService#isServiceUnitActive exception stack information (#13553)
new 3492116 Fix bug :Infinity value for CPU or Bandwidth usage (#13609)
new 9a25e59 [ Issue 13479 ] Fixed internal topic effect by
InactiveTopicPolicy. (#13611)
new 42f6b28 Fix the wrong multi-topic has message available behavior
(#13634)
new 00694f2 Fix getInternalStats occasional lack of LeaderInfo (#13656)
new 2e78d93 fix no response to client when handleSubscribe because
PendingAckHandleImpl init fail (#13655)
new f3bf499 Fix Flaky test
BacklogQuotaManagerTest.testConsumerBacklogEvictionTimeQuotaWithEmptyLedger
(#13724)
new c07764f Fix the deadlock while using zookeeper thread to create
ledger (#13744)
new 022d43b Fix invalid rack name cause bookie join rack failed (#13683)
new 2c73edd [Transaction] Fix recover of TransactionBuffer (#13739)
new 5d4fe65 Fix encrption bug with chunked message (#13689)
new 2804982 Fix inefficient forEach loop (#13742)
new 36f409a [Broker] Change create topic return error to
Status.BAD_REQUEST (#12919)
new 16aef57 [Issuse 13640][broker] Fix non persistent topic subscription
error. (#13685)
new ea3c064 fix ordering key with chunking (#13699)
new f36b701 Fix call sync method in async rest API for
``internalGetSubscriptionsForNonPartitionedTopic`` (#13745)
new 0bfd38e Release old bundle from ownership cache when operator split
bundle (#13678)
The 21 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 | 20 ++---
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 5 +-
pom.xml | 6 +-
.../apache/pulsar/broker/admin/AdminResource.java | 5 +-
.../pulsar/broker/admin/impl/BrokersBase.java | 3 +-
.../broker/admin/impl/PersistentTopicsBase.java | 55 ++++++------
.../pulsar/broker/admin/v1/PersistentTopics.java | 2 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 2 +-
.../BrokerInterceptorWithClassLoader.java | 31 +++++--
.../impl/GenericBrokerHostUsageImpl.java | 4 +-
.../loadbalance/impl/LinuxBrokerHostUsageImpl.java | 9 +-
.../pulsar/broker/namespace/NamespaceService.java | 10 ++-
.../pulsar/broker/service/AbstractTopic.java | 14 ++--
.../apache/pulsar/broker/service/ServerCnx.java | 3 +-
.../org/apache/pulsar/broker/service/Topic.java | 2 +
.../service/nonpersistent/NonPersistentTopic.java | 5 ++
.../broker/service/persistent/PersistentTopic.java | 23 +++--
.../broker/service/persistent/SystemTopic.java | 5 ++
.../pulsar/broker/systopic/SystemTopicClient.java | 6 +-
.../buffer/impl/TopicTransactionBuffer.java | 17 ++--
.../pendingack/PendingAckReplyCallBack.java | 6 ++
.../pendingack/impl/MLPendingAckReplyCallBack.java | 7 ++
.../pendingack/impl/MLPendingAckStore.java | 3 +
.../pendingack/impl/PendingAckHandleImpl.java | 7 ++
.../pulsar/broker/web/PulsarWebResource.java | 38 +++++++--
.../BrokerInterceptorWithClassLoaderTest.java | 97 +++++++++++++++++++++-
.../broker/namespace/NamespaceServiceTest.java | 43 ++++++++++
.../broker/service/BacklogQuotaManagerTest.java | 1 +
.../BrokerServiceAutoSubscriptionCreationTest.java | 14 ++++
.../broker/service/InactiveTopicDeleteTest.java | 49 +++++++++++
.../pulsar/broker/transaction/TransactionTest.java | 39 ++++++++-
.../client/api/SimpleProducerConsumerTest.java | 33 ++++++++
.../pulsar/client/impl/MessageChunkingTest.java | 25 ++++++
.../pulsar/client/impl/MultiTopicsReaderTest.java | 26 +++---
.../common/policies/data/impl/BookieInfoImpl.java | 10 +++
.../pulsar/client/impl/crypto/MessageCryptoBc.java | 1 +
.../pulsar/admin/cli/PulsarAdminToolTest.java | 18 ++++
.../org/apache/pulsar/admin/cli/CmdBookies.java | 13 +++
.../client/impl/MultiTopicsConsumerImpl.java | 2 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 11 ++-
.../collections/ConcurrentSortedLongPairSet.java | 14 ++--
.../ConcurrentSortedLongPairSetTest.java | 12 ++-
.../io/elasticsearch/ElasticSearchClient.java | 40 ++++-----
.../io/elasticsearch/ElasticSearchClientTests.java | 43 ++++++++++
pulsar-sql/presto-distribution/LICENSE | 30 +++----
pulsar-sql/presto-distribution/pom.xml | 4 +-
.../zookeeper/ZkBookieRackAffinityMapping.java | 5 +-
.../zookeeper/ZkBookieRackAffinityMappingTest.java | 29 +++++++
48 files changed, 683 insertions(+), 164 deletions(-)
