This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 83f7a3f4fe5 [improve][offloaders] Upgrade JClouds to 2.5.0 (#15649)
new fa227a06672 [improve][client] Avoid timertask run before previous
subscribe complete. (#14818)
new 95b5ef8be37 [C++] Fix UnknownError might be returned for a partitioned
producer (#15161)
new f682e105334 [enh][monitor]: add metrics for pulsar web service thread
pool (#14742)
new 28970b77bea Pulsar SQL support for Decimal data type (#15153)
new 421253790eb [fix][broker] Fix MessageDeduplication#inactiveProducers
may not be persistence correctly (#15206)
new a93a67b004a [Broker] Fix typo in enum name and handle closing of the
channel properly since writeAndFlush is asynchronous (#15384)
new 3673973a895 [Proxy/Client] Fix DNS server denial-of-service issue when
DNS entry expires (#15403)
new fd44570fca3 [Proxy] Remove unnecessary blocking DNS lookup in
LookupProxyHandler (#15415)
new 29104a70fae [Improve][doc] Add config of IO and acceptor threads in
proxy (#15340)
new d91c6d1b33d [improve][client] improve logic when ACK grouping tracker
checks duplicated message id (#15465)
new dfacc129931 Support handling single role and non-jwt-token in
MultiRolesTokenAuthorizationProvider (#14857)
new c312bcac62f Fix cherry-pick issue
The 12 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/proxy.conf | 6 ++
.../MultiRolesTokenAuthorizationProvider.java | 8 +-
.../PrometheusMetricsGeneratorUtils.java | 85 +++++++++++++++++
.../MultiRolesTokenAuthorizationProviderTest.java | 101 +++++++++++++++++++++
.../broker/service/ConnectionController.java | 16 ++--
.../apache/pulsar/broker/service/ServerCnx.java | 15 +--
.../service/persistent/MessageDeduplication.java | 13 ++-
.../apache/pulsar/broker/web/WebExecutorStats.java | 100 ++++++++++++++++++++
.../org/apache/pulsar/broker/web/WebService.java | 3 +
.../service/persistent/MessageDuplicationTest.java | 58 ++++++------
.../pulsar/broker/stats/PrometheusMetricsTest.java | 6 +-
.../apache/pulsar/broker/web/WebServiceTest.java | 44 ++++++++-
.../pulsar/client/impl/ConnectionPoolTest.java | 38 ++++----
pulsar-client-cpp/lib/PartitionedProducerImpl.cc | 55 +++++------
pulsar-client-cpp/lib/PartitionedProducerImpl.h | 12 +--
pulsar-client-cpp/pulsar-test-service-start.sh | 4 +
pulsar-client-cpp/tests/ProducerTest.cc | 43 +++++++++
.../apache/pulsar/client/impl/ConnectionPool.java | 53 +++++------
.../impl/PatternMultiTopicsConsumerImpl.java | 63 ++++++-------
.../PersistentAcknowledgmentsGroupingTracker.java | 5 +-
.../pulsar/proxy/server/LookupProxyHandler.java | 20 ++--
.../pulsar/proxy/server/ProxyConfiguration.java | 4 +-
.../pulsar/proxy/server/ProxyConnection.java | 16 ++--
.../apache/pulsar/proxy/server/ProxyService.java | 12 +--
.../proxy/server/ServiceChannelInitializer.java | 2 +-
pulsar-sql/presto-distribution/LICENSE | 2 -
pulsar-sql/presto-distribution/pom.xml | 1 -
.../decoder/avro/PulsarAvroColumnDecoder.java | 19 +++-
.../decoder/avro/PulsarAvroRowDecoderFactory.java | 10 +-
.../decoder/json/PulsarJsonRowDecoderFactory.java | 6 ++
.../pulsar/sql/presto/TestPulsarConnector.java | 15 ++-
.../pulsar/sql/presto/TestPulsarRecordCursor.java | 15 +++
.../sql/presto/decoder/AbstractDecoderTester.java | 5 +
.../sql/presto/decoder/DecoderTestMessage.java | 6 +-
.../pulsar/sql/presto/decoder/DecoderTestUtil.java | 20 ++++
.../sql/presto/decoder/avro/TestAvroDecoder.java | 25 ++++-
site2/docs/reference-configuration.md | 2 +
37 files changed, 691 insertions(+), 217 deletions(-)
create mode 100644
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGeneratorUtils.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebExecutorStats.java
