This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from ac932d5 [Transaction] Fix generate transactionId some comment.
(#13234)
new 8fa7139 [Issue #12485][Python Client] cannot use any values that
evaluates to False (#12489)
new c81aec3 [Config] Add readWorkerThreadsThrottlingEnabled to
conf/bookkeeper.conf (#12666)
new 757c121 Some depdency in integration tests scope should be test
(#12696)
new 9db66c3 [Pulsar SQL] Support query chunked messages feature in Pulsar
SQL (#12720)
new 49caf87 fix shedding heartbeat ns (#13208)
new 1510cf6 [Transaction] Fix performance (#13253)
new bff7916 [Transaction]No TransactionCoordinatorNotFound, but automatic
reconnect (#13135)
new 3e076bb [Broker] Modify return result of
NamespacesBase#internalGetPublishRate (#13237)
new b09fd87 [Transaction] Remove request if can not send (#13308)
new 22a24d6 [Transaction] Allow transaction be commit or abort in the
state of aborting or committing. (#13323)
new ebaf2b7 Fix Version.h not found when CMake binary directory is
customized (#13324)
new 7ca4552 [Transaction]stop TP replaying with Exception (#12700)
new 914f172 [Transaction] Delete the redundant code (#13327)
new b244d0c [Transaction]Txn client check timeout (#12521)
new 1d63246 Optimize transaction FieldUpdater to static final (#13396)
The 15 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
conf/bookkeeper.conf | 5 +
.../apache/bookkeeper/mledger/ManagedCursor.java | 6 +
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 1 +
.../mledger/impl/ManagedCursorContainerTest.java | 5 +
.../broker/TransactionMetadataStoreService.java | 8 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 8 +-
.../apache/pulsar/broker/admin/v1/Namespaces.java | 15 +-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 15 +-
.../apache/pulsar/broker/loadbalance/LoadData.java | 10 +
.../broker/loadbalance/impl/OverloadShedder.java | 8 +-
.../broker/loadbalance/impl/ThresholdShedder.java | 6 +-
.../pulsar/broker/namespace/NamespaceService.java | 6 +
.../apache/pulsar/broker/service/ServerCnx.java | 68 ++-
.../pendingack/impl/MLPendingAckStore.java | 25 +-
.../pulsar/common/naming/NamespaceBundle.java | 12 +
.../broker/namespace/NamespaceServiceTest.java | 9 +-
.../pulsar/broker/transaction/TransactionTest.java | 87 +++
.../broker/transaction/TransactionTestBase.java | 14 -
.../api/AuthorizationProducerConsumerTest.java | 2 +
.../client/impl/ConsumerAckResponseTest.java | 2 +
.../impl}/TransactionClientConnectTest.java | 218 +++-----
.../client/impl/TransactionEndToEndTest.java | 67 ++-
.../TransactionCoordinatorClientException.java | 20 +
pulsar-client-cpp/CMakeLists.txt | 1 +
.../python/pulsar/schema/definition.py | 6 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 4 +
.../client/impl/PartitionedProducerImpl.java | 5 +
.../apache/pulsar/client/impl/ProducerImpl.java | 13 +
.../pulsar/client/impl/PulsarClientImpl.java | 1 +
.../client/impl/TransactionMetaStoreHandler.java | 585 ++++++++++++++-------
.../impl/transaction/TransactionBuilderImpl.java | 9 +-
.../client/impl/transaction/TransactionImpl.java | 65 ++-
.../apache/pulsar/common/api/raw/RawMessage.java | 29 +
.../pulsar/common/api/raw/RawMessageImpl.java | 44 ++
.../pulsar/sql/presto/PulsarRecordCursor.java | 141 ++++-
.../pulsar/sql/presto/TestReadChunkedMessages.java | 214 ++++++++
.../pulsar/testclient/PerformanceConsumer.java | 14 +-
.../pulsar/testclient/PerformanceProducer.java | 15 +-
.../pulsar/testclient/PerformanceTransaction.java | 34 +-
.../pulsar/testclient/utils/PerformanceUtils.java | 59 ---
.../testclient/PerformanceTransactionTest.java | 25 +-
.../coordinator/impl/MLTransactionLogImpl.java | 2 +-
tests/integration/pom.xml | 2 +
43 files changed, 1339 insertions(+), 546 deletions(-)
rename pulsar-broker/src/test/java/org/apache/pulsar/{broker/transaction =>
client/impl}/TransactionClientConnectTest.java (50%)
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestReadChunkedMessages.java
delete mode 100644
pulsar-testclient/src/main/java/org/apache/pulsar/testclient/utils/PerformanceUtils.java
