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 09819b2458e [fix][broker] Fix broker LoadBalance uneffective (#15314)
new 702d21d8eba Support shrink in ConcurrentLongHashMap (#14497)
new aeb09298297 Optimize memory usage: support to shrink for pendingAcks
map (#14515)
new 14d9b8492d6 support shrink for map or set (#14663)
new 3ebc23e4bff Reduce unnecessary expansions for ConcurrentLong map and
set (#14562)
new 84a08942dd2 [fix][txn] Fix potentially unfinishable future. (#15208)
new d39c6551196 Upgrade Netty to 4.1.76.Final, Netty Tcnative, grpc and
protobuf (#15212)
new 98849cd5243 Skip unnecessary DNS resolution when creating
AuthenticationDataHttp instance (#15221)
new bb52721b88c TableView should cache created readers (#15178)
new 663ebe071a4 Improve skipping of DNS resolution when creating
AuthenticationDataHttp instance (#15228)
new dfe0d0d4bf9 [Build] Use grpc-bom to align grpc library versions
(#15234)
new c6c7d6dd41c Fix duplicate validateTopicOwnershipAsync (#15120)
new 4639b15c1de [Functions] Check executor null when closing the
FileSource (#15247)
new c2cfad82db1 [Fix][Broker] Fix race condition in `OpAddEntry` (#15233)
new 642159c8866 Pulsar SQL support for Decimal data type (#15153)
new 90caa1c621a Put `validateTopicOwnershipAsync` before
`validateTopicOperationAsync` (#15265)
new 83b68332af0 [C++] Remove the flaky and meaningless tests (#15271)
new 9122f93ea94 Fix typo in checkPermissionsAsync (#15273)
new bdb620369b8 [fix][tools] Only apply maxPendingMessagesAcrossPartitions
if it presents (#15283)
new 4ad4bd85544 Fix typo and doc in TopicPolies client api (#15293)
new efa28d74a45 [fix] [broker] Fix problem at RateLimiter#tryAcquire
(#15306)
new 536c8919824 [fix][client] Fix negative ack not redelivery. (#15312)
new 6d365c995a2 [C++] Wait until event loop terminates when closing the
Client (#15316)
new aef4dd202ca [fix][broker] fix resource group does not report usage
(#15292)
new 9352feb7a1c [improve][broker] Use shrink map for message redelivery.
(#15342)
new 0f15d122fbd [fix][broker] Fix MessageDeduplication#inactiveProducers
may not be persistence correctly (#15206)
new f7128614c1d [improve][broker] Support shrink for
ConcurrentSortedLongPairSet (#15354)
The 26 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:
buildtools/pom.xml | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 94 +--
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 10 +-
.../mledger/impl/ManagedLedgerOfflineBacklog.java | 3 +-
pom.xml | 79 +--
.../apache/pulsar/broker/ServiceConfiguration.java | 8 +
.../authentication/AuthenticationDataHttp.java | 2 +-
.../broker/TransactionMetadataStoreService.java | 11 +-
.../broker/admin/impl/PersistentTopicsBase.java | 284 ++++-----
.../broker/loadbalance/impl/LoadManagerShared.java | 20 +-
.../loadbalance/impl/ModularLoadManagerImpl.java | 18 +-
.../loadbalance/impl/SimpleLoadManagerImpl.java | 18 +-
.../pulsar/broker/namespace/NamespaceService.java | 13 +-
.../resourcegroup/ResourceQuotaCalculatorImpl.java | 4 +-
.../org/apache/pulsar/broker/rest/TopicsBase.java | 3 +-
.../pulsar/broker/service/BrokerService.java | 42 +-
.../org/apache/pulsar/broker/service/Consumer.java | 13 +-
.../apache/pulsar/broker/service/ServerCnx.java | 10 +-
.../service/nonpersistent/NonPersistentTopic.java | 12 +-
.../service/persistent/MessageDeduplication.java | 25 +-
.../persistent/MessageRedeliveryController.java | 11 +-
.../broker/service/persistent/PersistentTopic.java | 20 +-
.../broker/stats/ClusterReplicationMetrics.java | 3 +-
.../AntiAffinityNamespaceGroupTest.java | 15 +-
.../loadbalance/impl/LoadManagerSharedTest.java | 13 +-
.../ResourceQuotaCalculatorImplTest.java | 10 +
.../pulsar/broker/service/PersistentTopicTest.java | 24 +-
.../service/persistent/MessageDuplicationTest.java | 29 +-
.../MessageRedeliveryControllerTest.java | 2 +-
.../pulsar/client/impl/NegativeAcksTest.java | 3 +
.../apache/pulsar/client/admin/TopicPolicies.java | 20 +-
pulsar-client-cpp/lib/ClientImpl.cc | 37 +-
pulsar-client-cpp/lib/ExecutorService.cc | 33 +-
pulsar-client-cpp/lib/ExecutorService.h | 11 +-
pulsar-client-cpp/lib/TimeUtils.h | 48 ++
pulsar-client-cpp/tests/ClientTest.cc | 2 +-
pulsar-client-cpp/tests/CustomLoggerTest.cc | 26 +-
pulsar-client-cpp/tests/ProducerTest.cc | 83 ---
.../org/apache/pulsar/client/impl/ClientCnx.java | 22 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 3 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 3 +-
.../pulsar/client/impl/NegativeAcksTracker.java | 28 +-
.../client/impl/PartitionedProducerImpl.java | 3 +-
.../apache/pulsar/client/impl/ProducerBase.java | 3 +-
.../apache/pulsar/client/impl/TableViewImpl.java | 14 +
.../client/impl/TransactionMetaStoreHandler.java | 5 +-
.../TransactionCoordinatorClientImpl.java | 6 +-
.../impl/AcknowledgementsGroupingTrackerTest.java | 3 +-
.../org/apache/pulsar/common/util/RateLimiter.java | 3 +-
.../util/collections/ConcurrentLongHashMap.java | 149 ++++-
.../collections/ConcurrentLongLongPairHashMap.java | 673 +++++++++++++++++++++
.../util/collections/ConcurrentLongPairSet.java | 174 +++++-
.../util/collections/ConcurrentOpenHashMap.java | 159 ++++-
.../util/collections/ConcurrentOpenHashSet.java | 158 ++++-
.../collections/ConcurrentSortedLongPairSet.java | 32 +-
.../common/util/collections/LongPairSet.java | 7 +
.../apache/pulsar/common/util/RateLimiterTest.java | 20 +-
.../collections/ConcurrentLongHashMapTest.java | 141 ++++-
.../ConcurrentLongLongPairHashMapTest.java | 427 +++++++++++++
.../collections/ConcurrentLongPairSetTest.java | 130 +++-
.../collections/ConcurrentOpenHashMapTest.java | 144 ++++-
.../collections/ConcurrentOpenHashSetTest.java | 93 ++-
.../ConcurrentSortedLongPairSetTest.java | 43 ++
.../java/org/apache/pulsar/io/file/FileSource.java | 12 +-
pulsar-sql/presto-distribution/LICENSE | 63 +-
.../pulsar/sql/presto/PulsarRecordCursor.java | 3 +-
.../decoder/avro/PulsarAvroColumnDecoder.java | 19 +-
.../decoder/avro/PulsarAvroRowDecoderFactory.java | 10 +-
.../decoder/json/PulsarJsonRowDecoderFactory.java | 6 +
.../pulsar/sql/presto/TestPulsarConnector.java | 8 +-
.../pulsar/sql/presto/TestPulsarRecordCursor.java | 15 +
.../sql/presto/decoder/AbstractDecoderTester.java | 5 +
.../sql/presto/decoder/DecoderTestMessage.java | 6 +-
.../pulsar/sql/presto/decoder/DecoderTestUtil.java | 20 +
.../sql/presto/decoder/avro/TestAvroDecoder.java | 11 +
.../pulsar/testclient/PerformanceProducer.java | 4 +-
.../pulsar/testclient/PerformanceProducerTest.java | 21 +
.../apache/pulsar/websocket/WebSocketService.java | 23 +-
.../apache/pulsar/websocket/stats/ProxyStats.java | 4 +-
79 files changed, 3089 insertions(+), 645 deletions(-)
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMap.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMapTest.java
