You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by xi...@apache.org on 2022/06/22 06:45:25 UTC

[pulsar] branch master updated (33cf2d09502 -> c5056598cdd)

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

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


    from 33cf2d09502 [fix][client] Fix the startMessageId can't be respected as the ChunkMessageID (#16154)
     add c5056598cdd [Improve][txn] extend admin tools for transaction component. (#15675)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/broker/admin/impl/TransactionsBase.java |  9 ++--
 .../pulsar/broker/admin/v3/Transactions.java       | 11 +++--
 .../service/persistent/PersistentSubscription.java |  4 +-
 .../broker/service/persistent/PersistentTopic.java |  8 ++--
 .../transaction/buffer/TransactionBuffer.java      |  2 +-
 .../buffer/impl/InMemTransactionBuffer.java        |  2 +-
 .../buffer/impl/TopicTransactionBuffer.java        |  7 ++-
 .../buffer/impl/TransactionBufferDisable.java      |  2 +-
 .../transaction/pendingack/PendingAckHandle.java   |  2 +-
 .../pendingack/impl/PendingAckHandleDisabled.java  |  2 +-
 .../pendingack/impl/PendingAckHandleImpl.java      | 10 +++-
 .../broker/admin/v3/AdminApiTransactionTest.java   | 56 ++++++++++++++++++++--
 .../pulsar/broker/transaction/TransactionTest.java | 10 ++--
 .../buffer/TransactionStablePositionTest.java      |  4 +-
 .../apache/pulsar/client/admin/Transactions.java   | 56 ++++++++++++++++++++--
 .../policies/data/TransactionBufferStats.java      | 11 +++++
 .../policies/data/TransactionCoordinatorStats.java |  5 ++
 .../policies/data/TransactionPendingAckStats.java  | 12 +++++
 .../client/admin/internal/TransactionsImpl.java    | 18 ++++---
 .../pulsar/admin/cli/PulsarAdminToolTest.java      |  8 ++--
 .../apache/pulsar/admin/cli/CmdTransactions.java   | 12 ++++-
 .../impl/MLTransactionMetadataStore.java           |  1 +
 22 files changed, 203 insertions(+), 49 deletions(-)