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 f965fb8 [pulsar-broker] add uniform load shedder strategy to
distribute traffic uniformly across brokers (#12902)
add d7158dd PIP-45: Converted BookieRackAffinityMapping to use
MetadataStore (#12841)
No new revisions were added by this update.
Summary of changes:
pulsar-broker-common/pom.xml | 6 +
.../rackawareness/BookieRackAffinityMapping.java | 141 ++++++-----------
.../IsolatedBookieEnsemblePlacementPolicy.java | 106 ++++++-------
.../pulsar/broker/resources/BookieResources.java | 6 +-
.../zookeeper/ZkBookieRackAffinityMapping.java | 9 +-
.../ZkIsolatedBookieEnsemblePlacementPolicy.java | 12 +-
.../BookieRackAffinityMappingTest.java | 110 +++++--------
.../IsolatedBookieEnsemblePlacementPolicyTest.java | 174 +++++++--------------
.../apache/pulsar/PulsarClusterMetadataSetup.java | 6 +-
.../pulsar/broker/BookKeeperClientFactory.java | 10 +-
.../pulsar/broker/BookKeeperClientFactoryImpl.java | 85 +++-------
.../pulsar/broker/ManagedLedgerClientFactory.java | 7 +-
.../org/apache/pulsar/broker/PulsarService.java | 5 +-
.../pulsar/broker/service/BrokerService.java | 8 +-
.../service/schema/BookkeeperSchemaStorage.java | 11 +-
.../schema/BookkeeperSchemaStorageFactory.java | 5 +-
.../service/schema/SchemaStorageFactory.java | 3 +-
.../broker/storage/ManagedLedgerStorage.java | 4 +-
.../apache/pulsar/compaction/CompactorTool.java | 36 +++--
.../broker/BookKeeperClientFactoryImplTest.java | 42 ++---
.../broker/MockedBookKeeperClientFactory.java | 15 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 11 +-
.../OwnerShipForCurrentServerTestBase.java | 7 +-
.../broker/service/BrokerBookieIsolationTest.java | 10 +-
.../PersistentDispatcherFailoverConsumerTest.java | 9 +-
.../pulsar/broker/service/RackAwareTest.java | 4 +-
.../schema/BookkeeperSchemaStorageTest.java | 2 +-
.../broker/service/schema/SchemaServiceTest.java | 2 +-
.../broker/transaction/TransactionTestBase.java | 7 +-
.../client/impl/SequenceIdWithErrorTest.java | 2 +-
.../pulsar/zookeeper/LocalBookkeeperEnsemble.java | 4 +-
31 files changed, 328 insertions(+), 531 deletions(-)
rename
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkBookieRackAffinityMapping.java
=>
pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMapping.java
(56%)
rename
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java
=>
pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicy.java
(79%)
copy
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperCacheListener.java
=>
pulsar-broker-common/src/main/java/org/apache/pulsar/zookeeper/ZkBookieRackAffinityMapping.java
(77%)
copy
pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperCacheWatcher.java
=>
pulsar-broker-common/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java
(75%)
rename
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZkBookieRackAffinityMappingTest.java
=>
pulsar-broker-common/src/test/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMappingTest.java
(54%)
rename
pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicyTest.java
=>
pulsar-broker-common/src/test/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicyTest.java
(72%)
