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 131b455 [C++ Client] Add braces around initialization of subobject
(#14735)
new f9b0203 [Functions] Pass configured metricsPort to k8s runtime
(#14502)
new aafba1a Fix inconsistent prompt message when schema version is empty
using AVRO. (#14626)
new c69a376 Fixed flaky test MemoryLimitTest#testRejectMessages (#14220)
(#14628)
new 4aea15b [Broker] Ignore the print the log that the topic does not
exist (#13535)
new c83d04f Fix PartitionedProducerImpl flushAsync always fail when one
partition send TimeOutException (#14602)
new 1bea336 [ Issue 14633] [pulsar-broker] Fix metadata store deadlock
when checking BacklogQuota (#14634)
new 08eceb7 Fixed 404 error msg not being returned correctly using http
lookup. (#14677)
new a61aa5c Set splitNamespaceBundle with `readonly=false`. (#14680)
new 091ae73 fix incorrect warn log (#14685)
new 878a552 Fix race condition in consumer redelivery (#14687)
new 2c36f8b [pulsar-functions] fix some IOExceptions when create
functions from package URL (#14553)
new 2cb1681 [Broker] Fix precision issue and initial value for
Consumer#avgMessagesPerEntry (#14666)
new 1321201 Flaky-test:
SubscriptionSeekTest.testShouldCloseAllConsumersForMultipleConsumerDispatcherWhenSeek
(#14674)
new b5f3f24 [flaky-test]
SubscriptionSeekTest.testSeekForBatchMessageAndSpecifiedBatchIndex (#14676)
(#14689)
new 70a1fe1 Fix partitionsAutoUpdateFuture never complete (#14625)
new 1fae42d [Transaction] Fix transaction buffer recover
BrokerMetadataException close topic (#14709)
The 16 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/functions_worker.yml | 1 +
.../pulsar/broker/admin/impl/BrokersBase.java | 5 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 2 +-
.../broker/admin/impl/PersistentTopicsBase.java | 5 +-
.../pulsar/broker/service/BrokerService.java | 3 +-
.../org/apache/pulsar/broker/service/Consumer.java | 28 +++--
.../apache/pulsar/broker/service/ServerCnx.java | 5 +
.../PersistentDispatcherMultipleConsumers.java | 3 +-
.../PersistentDispatcherSingleActiveConsumer.java | 2 +-
.../buffer/impl/TopicTransactionBuffer.java | 5 +
.../apache/pulsar/broker/web/RestException.java | 6 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 14 +++
.../broker/service/PersistentTopicE2ETest.java | 13 +++
.../broker/service/SubscriptionSeekTest.java | 7 +-
.../TopicTransactionBufferRecoverTest.java | 64 ++++++++++-
.../pulsar/broker/transaction/TransactionTest.java | 3 +-
.../apache/pulsar/client/api/MemoryLimitTest.java | 86 +++++++-------
.../client/api/SimpleProducerConsumerTest.java | 127 +++++++++++++++++++++
.../java/org/apache/pulsar/schema/SchemaTest.java | 76 +++++++++++-
.../pulsar/client/admin/internal/PackagesImpl.java | 3 +-
.../client/impl/BinaryProtoLookupService.java | 8 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 18 +--
.../pulsar/client/impl/HttpLookupService.java | 5 +
.../client/impl/PartitionedProducerImpl.java | 19 ++-
.../apache/pulsar/client/impl/ProducerImpl.java | 42 ++++++-
.../runtime/kubernetes/KubernetesRuntime.java | 18 ++-
.../kubernetes/KubernetesRuntimeFactory.java | 7 +-
.../runtime/kubernetes/KubernetesRuntimeTest.java | 52 +++++++++
.../functions/worker/FunctionsStatsGenerator.java | 5 +-
.../functions/worker/rest/api/FunctionsImpl.java | 1 +
.../jcloud/impl/BlobStoreBackedReadHandleImpl.java | 2 +-
31 files changed, 543 insertions(+), 92 deletions(-)
