You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/08/31 02:35:07 UTC
[pulsar] branch master updated (3ff753c -> b4b77be)

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

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


    from 3ff753c  Add compaction threshold for topic level (#7881)
     add b4b77be  [Transaction] Consume transaction message logic optimized (#7833)

No new revisions were added by this update.

Summary of changes:
 .github/workflows/ci-unit-broker-broker-gp1.yaml   |  6 +-
 .../bookkeeper/mledger/impl/ManagedCursorImpl.java |  9 ++
 .../broker/TransactionMetadataStoreService.java    |  3 -
 .../broker/service/AbstractBaseDispatcher.java     | 40 ++++-----
 .../org/apache/pulsar/broker/service/Consumer.java |  6 +-
 .../org/apache/pulsar/broker/service/Producer.java |  2 +-
 .../org/apache/pulsar/broker/service/Topic.java    |  3 +-
 .../NonPersistentDispatcherMultipleConsumers.java  |  2 +-
 ...onPersistentDispatcherSingleActiveConsumer.java |  2 +-
 ...istentStickyKeyDispatcherMultipleConsumers.java |  2 +-
 .../service/nonpersistent/NonPersistentTopic.java  |  2 +-
 .../PersistentDispatcherMultipleConsumers.java     |  9 +-
 .../PersistentDispatcherSingleActiveConsumer.java  |  6 +-
 ...istentStickyKeyDispatcherMultipleConsumers.java |  3 +-
 .../broker/service/persistent/PersistentTopic.java |  4 +-
 .../service/persistent/TransactionReader.java      | 95 ++++++++++++++++------
 .../transaction/buffer/TransactionBuffer.java      |  3 +-
 .../transaction/buffer/TransactionEntry.java       | 10 +--
 .../broker/transaction/buffer/TransactionMeta.java | 12 ++-
 ...eption.java => TransactionStatusException.java} |  8 +-
 .../buffer/impl/InMemTransactionBuffer.java        | 26 +++---
 .../buffer/impl/InMemTransactionBufferReader.java  |  3 +-
 .../buffer/impl/PersistentTransactionBuffer.java   | 16 ++--
 .../impl/PersistentTransactionBufferReader.java    | 12 ++-
 .../buffer/impl/TransactionEntryImpl.java          | 61 +++++++++++++-
 .../buffer/impl/TransactionMetaImpl.java           | 18 +++-
 .../broker/transaction/TransactionConsumeTest.java | 75 ++++++++++++-----
 .../broker/transaction/TransactionProduceTest.java | 25 ++----
 .../broker/transaction/TransactionTestBase.java    | 23 +++---
 .../buffer/PersistentTransactionBufferTest.java    | 10 +--
 .../transaction/buffer/TransactionBufferTest.java  |  5 +-
 .../buffer/TransactionEntryImplTest.java           |  5 +-
 .../coordinator/TransactionMetaStoreTestBase.java  |  1 +
 .../pulsar/client/transaction/EndToEndTest.java    | 42 +++++++---
 .../apache/pulsar/client/impl/ConsumerImpl.java    | 19 ++++-
 .../client/impl/TypedMessageBuilderImpl.java       |  5 +-
 36 files changed, 392 insertions(+), 181 deletions(-)
 rename pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/{UnexpectedTxnStatusException.java => TransactionStatusException.java} (83%)