(pulsar) branch lh-fix-fenced-ledger-fail-pending updated (7f76b11c24fa -> 2a4054401ecd)

[lh...@apache.org]

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

lhotari pushed a change to branch lh-fix-fenced-ledger-fail-pending
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from 7f76b11c24fa Address review comments
     add d1c887bd4866 [fix][meta] Preserve ownership during underreplication lock cleanup (#26794)
     add f78fa57251ab [fix][admin] Use ClientConfigurationData timeout params to set AsyncHttpConnector timeout params (#25040)
     add 75e6f554b62d [improve][broker] Don't compute Key_Shared consumers' key hash ranges for stats without the consumers (#26965)
     add e7ce9a2227b5 [BUG] Fix stats in PulsarZooKeeperClient multi. (#25766)
     add 6c88df54b613 [fix][broker] Avoid false WARN log when replicator is already terminated (#25259)
     add 4dec637c1e5e [fix][broker] The configuration subscriptionExpirationTimeMinutes does not work if the topic was reloaded frequently (#25244)
     add 846f21bc578c [feat][monitor] PIP-320: Add OpenTelemetry metrics for the Function Worker (#26823)
     add 90e4a2ecccc8 [fix][metadata] Invalidate ledger metadata cache on version conflicts (#26940)
     add 24c442abb5a5 [fix][meta] Fix leader election close deleting a leader node owned by another session (#26828)
     add 998b01b58fb6 [fix][ml] Complete the original future after ledger deletion retries (#26742)
     add abc9955a5acd [fix][broker] Prevent stale messages from surviving compaction retries (#26664)
     add ae1a9be736e4 [fix][client] Fix retry logic for BinaryProtoLookupService.getTopicsUnderNamespace method (#24974)
     add 4c49b154431f [fix][broker] Producer still publishes messages to Broker after Topic was unloaded (#24793)
     add ecdd47d51257 [fix][meta] Fix underreplication locks left behind when closing by handling each deletion independently (#26674)
     add 19f589f8178b [improve][ml] Optimization method getNumberOfEntries (#23576)
     add 9d48d8e6d4e8 [improve][client] Don't start a batch receive on an internal consumer without queued messages (#26966)
     add a2c5e03f8942 [fix][broker] Use the uncompressed payload when finding the last message position of a compacted batch (#26962)
     add f122d2100600 [fix][broker] Fix partitioned topic auto deletion http request timeout (#24912)
     add 2a4054401ecd Merge branch 'master' into lh-fix-fenced-ledger-fail-pending

No new revisions were added by this update.

Summary of changes:
 .../apache/bookkeeper/mledger/ManagedCursor.java   |   10 +
 .../bookkeeper/mledger/impl/ManagedCursorImpl.java |   62 +-
 .../bookkeeper/mledger/impl/ManagedLedgerImpl.java |   12 +-
 managed-ledger/src/main/proto/MLDataFormats.proto  |    8 +-
 .../mledger/impl/ManagedCursorIdleTest.java        |  198 +++
 .../bookkeeper/mledger/impl/ManagedCursorTest.java |    4 +
 .../mledger/impl/ManagedLedgerDeleteRetryTest.java |  125 ++
 .../broker/admin/impl/PersistentTopicsBase.java    |   83 +-
 .../pulsar/broker/service/AbstractReplicator.java  |    2 +-
 .../pulsar/broker/service/AbstractTopic.java       |   68 +-
 .../service/persistent/PersistentSubscription.java |    8 +-
 .../compaction/PulsarTopicCompactionService.java   |    2 +-
 .../compaction/StrategicTwoPhaseCompactor.java     |   63 +-
 .../CustomizedManagedLedgerStorageForTest.java     |    5 +
 .../impl/InactiveSubscriptionTopicReloadTest.java  |   94 ++
 .../broker/service/AbstractReplicatorTest.java     |   70 ++
 .../pulsar/broker/service/AbstractTopicTest.java   |   62 +
 .../broker/service/InactiveTopicDeleteTest.java    |    3 +
 .../pulsar/broker/stats/ConsumerStatsTest.java     |   27 +
 ...MultiListenersWithInternalListenerNameTest.java |    6 +-
 .../apache/pulsar/compaction/CompactorTest.java    |   42 +
 .../compaction/StrategicCompactorBkTest.java       |  106 ++
 .../admin/internal/http/AsyncHttpConnector.java    |   16 +-
 .../internal/http/AsyncHttpConnectorProvider.java  |    2 +-
 .../client/admin/internal/PulsarAdminImplTest.java |   35 +
 .../client/impl/BinaryProtoLookupService.java      |  109 +-
 .../client/impl/MultiTopicsConsumerImpl.java       |    5 +-
 .../pulsar/client/impl/PulsarClientImpl.java       |    3 +-
 .../client/impl/BinaryProtoLookupServiceTest.java  |  169 ++-
 pulsar-functions/worker/build.gradle.kts           |    1 +
 .../functions/worker/OpenTelemetryWorkerStats.java |  241 ++++
 .../functions/worker/PulsarWorkerService.java      |    8 +-
 .../functions/worker/WorkerStatsManager.java       |   88 +-
 .../pulsar/functions/worker/rest/WorkerServer.java |    7 +-
 .../worker/OpenTelemetryWorkerStatsTest.java       |  218 ++++
 .../metadata/bookkeeper/PulsarLedgerManager.java   |   10 +-
 .../PulsarLedgerUnderreplicationManager.java       |  191 ++-
 .../coordination/impl/LeaderElectionImpl.java      |   29 +-
 .../pulsar/metadata/impl/DualMetadataStore.java    |  130 +-
 .../metadata/impl/PulsarZooKeeperClient.java       |    2 +-
 .../LeaderElectionStaleLeaderCloseTest.java        |  144 +++
 .../LedgerUnderreplicationManagerTest.java         | 1322 +++++++++++++++++++-
 .../bookkeeper/PulsarLedgerManagerCacheTest.java   |  150 +++
 ...lsarLedgerUnderreplicationManagerCloseTest.java |  467 +++++++
 44 files changed, 4157 insertions(+), 250 deletions(-)
 create mode 100644 managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorIdleTest.java
 create mode 100644 managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerDeleteRetryTest.java
 create mode 100644 pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/InactiveSubscriptionTopicReloadTest.java
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/compaction/StrategicCompactorBkTest.java
 create mode 100644 pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/OpenTelemetryWorkerStats.java
 create mode 100644 pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/OpenTelemetryWorkerStatsTest.java
 create mode 100644 pulsar-metadata/src/test/java/org/apache/pulsar/metadata/LeaderElectionStaleLeaderCloseTest.java
 create mode 100644 pulsar-metadata/src/test/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManagerCacheTest.java
 create mode 100644 pulsar-metadata/src/test/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManagerCloseTest.java