You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by bo...@apache.org on 2022/09/14 06:06:54 UTC

[pulsar] branch master updated (6bc30163cec -> 57317d6576a)

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

bogong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from 6bc30163cec [feat][broker][PIP-195] New bucket based delayed message tracker - interface&config&proto -part 1 (#17344)
     add 57317d6576a [improve][txn] PIP-160 Metrics stats of Transaction buffered writer (#16758)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/pulsar/broker/PulsarService.java    |   2 +
 .../TransactionBatchedWriteValidator.java          |  56 +++
 .../pulsar/broker/validator}/package-info.java     |   2 +-
 .../pendingack/impl/MLPendingAckStoreTest.java     |  30 +-
 .../coordinator/impl/TxnLogBufferedWriter.java     | 428 +++++++++-------
 .../impl/TxnLogBufferedWriterMetricsStats.java     | 208 ++++++++
 .../coordinator/impl/TxnLogBufferedWriterTest.java | 536 +++++++++++++++++++--
 7 files changed, 1033 insertions(+), 229 deletions(-)
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/validator/TransactionBatchedWriteValidator.java
 copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util => pulsar-broker/src/main/java/org/apache/pulsar/broker/validator}/package-info.java (94%)
 create mode 100644 pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/TxnLogBufferedWriterMetricsStats.java