This is an automated email from the ASF dual-hosted git repository. daojun pushed a commit to branch dev/grpc_schema_storage in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 3d34484df528349c15aac0eacb1fe83edda5aba1 Merge: e1d49c1245e 6bbaec1f6b1 Author: DaoJun <[email protected]> AuthorDate: Tue Jul 30 17:13:05 2024 +0800 Merge branch 'refs/heads/master' into dev/grpc_schema_storage .github/workflows/ci-maven-cache-update.yaml | 2 +- .github/workflows/ci-owasp-dependency-check.yaml | 2 +- .github/workflows/pulsar-ci-flaky.yaml | 2 +- .github/workflows/pulsar-ci.yaml | 20 +- .mvn/extensions.xml | 2 +- docker/pulsar-all/pom.xml | 4 +- docker/pulsar/pom.xml | 4 +- pom.xml | 2 +- .../apache/pulsar/PulsarClusterMetadataSetup.java | 51 ++- .../org/apache/pulsar/broker/PulsarService.java | 2 +- .../extensions/ExtensibleLoadManagerImpl.java | 3 +- .../loadbalance/impl/ModularLoadManagerImpl.java | 3 +- .../pulsar/broker/service/AbstractTopic.java | 20 +- .../org/apache/pulsar/broker/service/Consumer.java | 151 ++++---- .../apache/pulsar/broker/service/ServerCnx.java | 19 + .../SystemTopicTxnBufferSnapshotService.java | 15 +- .../TransactionBufferSnapshotServiceFactory.java | 26 +- .../service/persistent/PersistentSubscription.java | 54 ++- .../broker/service/persistent/PersistentTopic.java | 108 +++--- .../SingleSnapshotAbortedTxnProcessorImpl.java | 73 +--- .../SnapshotSegmentAbortedTxnProcessorImpl.java | 394 +++++++++------------ .../broker/transaction/buffer/impl/TableView.java | 97 +++++ .../buffer/impl/TopicTransactionBuffer.java | 5 +- .../java/org/apache/pulsar/utils/SimpleCache.java | 83 +++++ .../apache/pulsar/broker/admin/AdminApi2Test.java | 77 +++- .../apache/pulsar/broker/service/Ipv4Proxy.java | 197 +++++++++++ .../broker/service/NetworkErrorTestBase.java | 297 ++++++++++++++++ .../pulsar/broker/service/PersistentTopicTest.java | 79 ++--- .../pulsar/broker/service/ZkSessionExpireTest.java | 184 ++++++++++ .../TopicTransactionBufferRecoverTest.java | 46 ++- .../TransactionCoordinatorClientTest.java | 24 ++ .../broker/zookeeper/ClusterMetadataSetupTest.java | 43 +++ .../apache/pulsar/client/api/MaxProducerTest.java | 88 +++++ .../pulsar/client/impl/NegativeAcksTest.java | 13 +- .../org/apache/pulsar/utils/SimpleCacheTest.java | 81 +++++ .../apache/pulsar/client/impl/ConsumerImpl.java | 2 +- .../client/impl/TransactionMetaStoreHandler.java | 26 +- .../TransactionCoordinatorClientImpl.java | 4 +- .../metadata/impl/AbstractMetadataStore.java | 10 + 39 files changed, 1697 insertions(+), 616 deletions(-)
