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 e486492 Revert "Creating a topic does not wait for creating cursor of
replicators (#6364)" (#10674)
add d94c3f0 PIP-45: Initialize ManagedLedgerFactory with MetadataStore
(#10647)
No new revisions were added by this update.
Summary of changes:
.../mledger/impl/ManagedCursorMXBeanImpl.java | 3 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 121 ++++++---------
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 9 +-
.../mledger/impl/ReadOnlyManagedLedgerImpl.java | 4 +-
.../mledger/impl/EntryCacheManagerTest.java | 44 +++---
.../mledger/impl/ManagedCursorPropertiesTest.java | 4 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 136 ++++++++---------
.../mledger/impl/ManagedLedgerBkTest.java | 67 ++++----
.../mledger/impl/ManagedLedgerErrorsTest.java | 128 ++++++++--------
.../ManagedLedgerFactoryChangeLedgerPathTest.java | 11 +-
.../mledger/impl/ManagedLedgerMBeanTest.java | 2 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 106 ++++++-------
.../bookkeeper/mledger/impl/MetaStoreImplTest.java | 77 ++++------
.../mledger/impl/NonDurableCursorTest.java | 9 +-
.../bookkeeper/mledger/impl/OffloadPrefixTest.java | 4 +-
.../mledger/offload/OffloadUtilsTest.java | 2 +-
.../bookkeeper/test/BookKeeperClusterTestCase.java | 44 +++---
.../bookkeeper/test/MockedBookKeeperTestCase.java | 36 ++---
.../pulsar/PulsarClusterMetadataTeardown.java | 100 +++++-------
.../pulsar/broker/BookKeeperClientFactoryImpl.java | 1 +
.../pulsar/broker/ManagedLedgerClientFactory.java | 7 +-
.../org/apache/pulsar/broker/PulsarService.java | 2 +-
.../broker/storage/ManagedLedgerStorage.java | 5 +-
.../broker/MockedBookKeeperClientFactory.java | 13 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 19 +--
.../intercept/MangedLedgerInterceptorImplTest.java | 9 +-
.../OwnerShipForCurrentServerTestBase.java | 22 +--
.../PersistentDispatcherFailoverConsumerTest.java | 18 +--
.../service/PersistentTopicConcurrentTest.java | 6 +-
.../pulsar/broker/service/PersistentTopicTest.java | 2 +-
.../pulsar/broker/service/ServerCnxTest.java | 2 +-
.../persistent/PersistentSubscriptionTest.java | 10 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 12 +-
.../broker/transaction/TransactionTestBase.java | 22 +--
.../client/impl/SequenceIdWithErrorTest.java | 4 +-
.../metadata/impl/FaultInjectionMetadataStore.java | 169 +++++++++++++++++++++
.../bookkeeper/test/BookKeeperClusterTestCase.java | 22 ++-
.../bookkeeper/test/MockedBookKeeperTestCase.java | 33 ++--
.../pulsar/sql/presto/PulsarConnectorCache.java | 13 +-
.../pulsar/testclient/ManagedLedgerWriter.java | 10 +-
.../MLTransactionMetadataStoreTest.java | 21 ++-
.../coordinator/test/MockedBookKeeperTestCase.java | 30 ++--
.../bookkeeper/client/PulsarMockBookKeeper.java | 23 +--
.../cli/ClusterMetadataTearDownTest.java | 28 ++--
.../impl/FileSystemManagedLedgerOffloaderTest.java | 14 +-
.../impl/BlobStoreManagedLedgerOffloaderBase.java | 14 +-
46 files changed, 775 insertions(+), 663 deletions(-)
create mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/FaultInjectionMetadataStore.java
