You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/03/14 15:25:57 UTC
[pulsar] branch master updated (fe7e55d -> 1d10dff)

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from fe7e55d  [Broker] Ignore the print the log that the topic does not exist (#13535)
     add 1d10dff  support shrink for map or set (#14663)

No new revisions were added by this update.

Summary of changes:
 .../mledger/impl/ManagedLedgerOfflineBacklog.java  |   3 +-
 .../broker/loadbalance/impl/LoadManagerShared.java |  20 ++-
 .../loadbalance/impl/ModularLoadManagerImpl.java   |  18 ++-
 .../loadbalance/impl/SimpleLoadManagerImpl.java    |  18 ++-
 .../pulsar/broker/namespace/NamespaceService.java  |  13 +-
 .../org/apache/pulsar/broker/rest/TopicsBase.java  |   3 +-
 .../pulsar/broker/service/BrokerService.java       |  42 ++++--
 .../service/nonpersistent/NonPersistentTopic.java  |  12 +-
 .../service/persistent/MessageDeduplication.java   |  12 +-
 .../broker/service/persistent/PersistentTopic.java |  20 ++-
 .../broker/stats/ClusterReplicationMetrics.java    |   3 +-
 .../AntiAffinityNamespaceGroupTest.java            |  15 ++-
 .../loadbalance/impl/LoadManagerSharedTest.java    |  13 +-
 .../pulsar/broker/service/PersistentTopicTest.java |  24 +++-
 .../apache/pulsar/client/impl/ConsumerBase.java    |   3 +-
 .../apache/pulsar/client/impl/ConsumerImpl.java    |   3 +-
 .../client/impl/PartitionedProducerImpl.java       |   3 +-
 .../apache/pulsar/client/impl/ProducerBase.java    |   3 +-
 .../impl/AcknowledgementsGroupingTrackerTest.java  |   3 +-
 .../util/collections/ConcurrentLongPairSet.java    | 148 +++++++++++++++++++--
 .../util/collections/ConcurrentOpenHashMap.java    | 140 +++++++++++++++++--
 .../util/collections/ConcurrentOpenHashSet.java    | 140 +++++++++++++++++--
 .../collections/ConcurrentSortedLongPairSet.java   |   5 +-
 .../collections/ConcurrentLongPairSetTest.java     | 111 +++++++++++++---
 .../collections/ConcurrentOpenHashMapTest.java     | 125 ++++++++++++++---
 .../collections/ConcurrentOpenHashSetTest.java     |  73 +++++++++-
 .../pulsar/sql/presto/PulsarRecordCursor.java      |   3 +-
 .../apache/pulsar/websocket/WebSocketService.java  |  23 +++-
 .../apache/pulsar/websocket/stats/ProxyStats.java  |   4 +-
 29 files changed, 860 insertions(+), 143 deletions(-)