You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2026/10/17 02:46:06 UTC
(pulsar) branch branch-4.2 updated (317accb252fc -> d2bd02abcf6e)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 317accb252fc [fix][misc] Upgrade jline to avoid cve (#26930)
add c2c078da2301 [improve][broker] Add reason label for topic_load_failed_total (#26264)
add 1b518eb4b884 [improve][broker] trace topic loading latency and timeout states (#26666)
add f65d1f8066bc [fix][test] Fix flaky LatencyTracerTest.testTraceFuture (#26741)
add 259305837bb8 [fix][client] Don't retry a Pulsar Admin request after its request timeout has elapsed (#26881)
add 82eaa62f28e6 [improve][build] Upgrade LightProto to 0.9.3 (#26893)
add 81a4233f77f0 [fix][offload] Fix NPE when reading from a closed offloaded read handle by keeping its ledger metadata (#26891)
add 31d96c9faad1 [fix][schema] Fix Protobuf native descriptor deserialization (#26725)
add 408dfb12f146 [fix][meta] Return LedgerExistException for duplicate ledger creation (#26669)
add 3bc1b06a038e [fix][broker] Prevent stale consumer removal from removing replacements (#26652)
add 8b41840d9164 [fix][broker] Fix web service close hang when the Jetty server fails to start (#26895)
add 26c2736e8d6a [fix][broker] Handle synchronous schema lookup failures in replication (#26108)
add 2d615be561db [fix] [client] chunked message uuid-queue never removes entries on successful processing (#26658)
add b55d00be0b7b [fix][broker] Match namespace isolation policy brokers given as host:port (#26829)
add 134b38c3938e [fix][client] Return flow-control permit when client seek by messageID (#26726)
add fc4365728293 [fix][ml] Wait for managed ledgers to close on factory shutdown, bounding each close (#26063)
add a299f0129b21 [fix][schema] Fix BookKeeper read handle leaks on schema read failures (#26818)
add 7928c450db8b [fix][client] Prevent chunk message ID leaks after seek (#26909)
add 1889e0b4201b [fix][managed-ledger] Persist partial batch ACKs on flush (#26765)
add 08bd6c210016 [fix][client] Release connections on partition metadata rejection (#26912)
add 37539b061d13 [fix][broker] Honor dynamic decreases of dispatcherMaxReadBatchSize (#26908)
add 0bc3604f2307 [fix][broker] Prevent duplicate messages when reconnect races with purge (#26907)
add ae00d608d867 [fix][broker] Prevent bundle split hangs on executor rejection (#26905)
add 047a4eaafc1e [fix][broker] Clean up orphan schema ledgers after write failures (#26902)
add a8201ba2df77 [fix][client] Serialize chunked-message bookkeeping to fix use-after-free and count/queue drift (#26084)
add 502de9c7450c [fix][broker] Preserve unacked backpressure for stale redelivery requests (#26910)
add 19a1725abb1e [fix][client] Make chunking inert on non-persistent topics, including the message-size checks (#26550)
add 435ae2e24a6e [fix][client] Schedule TableView tail-read retries instead of sleeping on the callback thread (#26672)
add f8f1dd869419 [fix][ml] Serialize a cursor's reused position info under its monitor (#26944)
add 3ea48915f598 [fix][broker] Fix inflated rate stats of newly created consumers (#26928)
add d2bd02abcf6e [fix][broker] PIP-442: Fix unbounded executor queue growth and single-thread bottleneck in the topic list memory limiter (#26929)
No new revisions were added by this update.
Summary of changes:
build/run_unit_group.sh | 2 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 81 ++-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 136 ++--
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 39 +-
.../impl/ManagedCursorBatchAckRecoveryTest.java | 57 ++
...anagedCursorPersistPositionConcurrencyTest.java | 114 ++++
.../mledger/impl/ManagedLedgerFactoryTest.java | 109 ++++
pip/pip-382.md | 40 +-
pom.xml | 2 +-
.../pulsar/broker/web/WebExecutorThreadPool.java | 20 +
.../broker/web/WebExecutorThreadPoolTest.java | 75 +++
.../pulsar/broker/admin/impl/ClustersBase.java | 10 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 7 +-
.../broker/loadbalance/impl/LoadManagerShared.java | 31 +-
.../impl/SimpleResourceAllocationPolicies.java | 16 +
.../pulsar/broker/namespace/NamespaceService.java | 51 +-
.../AbstractDispatcherMultipleConsumers.java | 18 +
.../pulsar/broker/service/BrokerService.java | 148 +++--
.../org/apache/pulsar/broker/service/Consumer.java | 23 +-
...ashRangeExclusiveStickyKeyConsumerSelector.java | 2 +-
.../apache/pulsar/broker/service/PulsarStats.java | 5 +-
.../pulsar/broker/service/TopicLoadingContext.java | 112 +++-
.../broker/service/TopicLoadingTracePoints.java | 46 ++
.../persistent/GeoPersistentReplicator.java | 6 +-
.../service/persistent/MessageDeduplication.java | 30 +-
.../PersistentDispatcherMultipleConsumers.java | 15 +-
...rsistentDispatcherMultipleConsumersClassic.java | 11 +-
.../PersistentDispatcherSingleActiveConsumer.java | 5 +-
.../service/persistent/PersistentReplicator.java | 40 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 7 +
.../broker/service/persistent/PersistentTopic.java | 21 +-
.../service/schema/BookkeeperSchemaStorage.java | 43 +-
.../broker/stats/BrokerOperabilityMetrics.java | 45 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 57 ++
.../loadbalance/impl/LoadManagerSharedTest.java | 95 +++
.../NamespaceServiceSplitFailureTest.java | 178 +++++
.../pulsar/broker/service/BrokerServiceTest.java | 197 +++++-
.../broker/service/OneWayReplicatorTest.java | 118 ++++
...dSubscriptionUnackedMessagesAccountingTest.java | 143 ++++
.../broker/service/SubscriptionSeekTest.java | 191 ++++++
.../persistent/GeoPersistentReplicatorTest.java | 277 ++++++++
.../service/persistent/MessageDuplicationTest.java | 108 +++
...tDispatcherMultipleConsumersReadLimitsTest.java | 106 +++
.../BookkeeperSchemaStorageReadHandleTest.java | 184 ++++++
.../broker/service/schema/SchemaServiceTest.java | 147 +++++
.../pulsar/broker/stats/ConsumerStatsTest.java | 41 ++
.../pulsar/broker/stats/PrometheusMetricsTest.java | 7 +-
.../buffer/TopicTransactionBufferTest.java | 3 +-
.../pulsar/client/api/ConsumerRedeliveryTest.java | 65 ++
.../api/ConsumerRedeliveryTransactionTest.java | 258 ++++++++
.../pulsar/client/impl/ConnectionPoolTest.java | 88 +++
.../pulsar/client/impl/MessageChunkingTest.java | 528 +++++++++++++++
.../admin/internal/http/AsyncHttpConnector.java | 33 +-
.../internal/http/AsyncHttpConnectorTest.java | 115 +++-
.../admin/cli/CmdNamespaceIsolationPolicy.java | 8 +-
.../client/impl/BinaryProtoLookupService.java | 1 +
.../apache/pulsar/client/impl/ConsumerImpl.java | 258 ++++++--
.../apache/pulsar/client/impl/ProducerImpl.java | 22 +-
.../apache/pulsar/client/impl/TableViewImpl.java | 197 +++++-
.../impl/schema/ProtobufNativeSchemaUtils.java | 113 +++-
.../client/impl/BatchMessageContainerImplTest.java | 145 ++++
.../pulsar/client/impl/ConsumerImplTest.java | 693 +++++++++++++++++++-
.../client/impl/TableViewBuilderImplTest.java | 2 +
.../pulsar/client/impl/TableViewImplTest.java | 726 +++++++++++++++++++++
.../impl/schema/ProtobufNativeSchemaUtilsTest.java | 179 ++++-
.../common/policies/NamespaceIsolationPolicy.java | 26 +
.../policies/impl/NamespaceIsolationPolicies.java | 17 +
.../impl/NamespaceIsolationPolicyImpl.java | 67 +-
.../semaphore/AsyncDualMemoryLimiterImpl.java | 35 +-
.../common/semaphore/AsyncSemaphoreImpl.java | 179 +++--
.../apache/pulsar/common/util/LatencyTracer.java | 288 +++++++-
.../impl/NamespaceIsolationPolicyImplTest.java | 80 +++
.../semaphore/AsyncDualMemoryLimiterImplTest.java | 54 ++
.../common/semaphore/AsyncSemaphoreImplTest.java | 128 ++++
.../pulsar/common/util/LatencyTracerTest.java | 198 +++++-
.../metadata/bookkeeper/PulsarLedgerManager.java | 19 +-
.../pulsar/metadata/bookkeeper/EndToEndTest.java | 100 +++
.../bookkeeper/PulsarLedgerManagerTest.java | 167 +++++
.../jcloud/impl/BlobStoreBackedReadHandleImpl.java | 6 +-
.../impl/BlobStoreBackedReadHandleImplV2.java | 8 +-
...obStoreManagedLedgerOffloaderStreamingTest.java | 51 ++
.../impl/BlobStoreManagedLedgerOffloaderTest.java | 30 +
82 files changed, 7616 insertions(+), 487 deletions(-)
create mode 100644 managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorPersistPositionConcurrencyTest.java
create mode 100644 pulsar-broker-common/src/test/java/org/apache/pulsar/broker/web/WebExecutorThreadPoolTest.java
create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicLoadingTracePoints.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicatorTest.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorageReadHandleTest.java
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerRedeliveryTransactionTest.java
create mode 100644 pulsar-metadata/src/test/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManagerTest.java