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 1a32edc Fixes the NPE in system topics policies service (#13469)
new 7aac8b8 [Issue 9888] add python3.9 on manylinux2014 build support
(#10954)
new 4f876678 Add log error tracking for semaphore count leak (#12410)
new 1a1c886 Apply clang-format check for python wrapper (#13418)
new b763f83 [Producer] Change the time units from ns to ms (#13057)
new 25c3ae3 Fix dead loop in BacklogQuotaManager.dropBacklogForTimeLimit
(#13194) (#13249)
new ef9e773 Fix semaphore and memory leak when chunks failed to enqueue
(#13454)
new c9c48d2 Fix getting last message id from empty compact ledger (#13476)
new cac6942 fix: bug when allAll bucket (#13467)
new 77c66b3 Fix reousrce leak when create producer failed (#13505)
new 2a73cdf Use PulsarByteBufAllocator to allocate buffer for chunks at
consumer side (#13536)
new 078c8db [Pulsar SQL] support protobuf/timestamp (#13287)
new bdfa14d Return message ID from compacted ledger while the compaction
cursor reach the end of the topic (#13533)
new 3644311 [Security] Upgrade Log4j to 2.17.1 (#13552)
The 13 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:
...entos7.yaml => ci-python-build-3.9-client.yaml} | 11 +-
buildtools/pom.xml | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 10 +-
.../bookkeeper/mledger/util/StatsBuckets.java | 2 +-
.../bookkeeper/mledger/util/TestStatsBuckets.java | 13 +
pom.xml | 2 +-
.../pulsar/broker/service/BacklogQuotaManager.java | 28 +-
.../apache/pulsar/broker/service/ServerCnx.java | 5 +-
.../apache/pulsar/compaction/CompactedTopic.java | 2 +
.../pulsar/compaction/CompactedTopicImpl.java | 21 +-
.../broker/service/BacklogQuotaManagerTest.java | 48 ++
.../broker/service/ExclusiveProducerTest.java | 28 +
.../broker/service/TopicTerminationTest.java | 29 +
.../pulsar/client/impl/MessageChunkingTest.java | 43 +
.../pulsar/compaction/CompactedTopicTest.java | 86 +-
pulsar-client-cpp/CMakeLists.txt | 6 +-
...-build-centos7.sh => docker-build-python3.9.sh} | 27 +-
pulsar-client-cpp/docker/build-wheels.sh | 1 +
pulsar-client-cpp/docker/create-images.sh | 17 +-
.../docker/{ => manylinux1}/Dockerfile | 21 +-
.../docker/{ => manylinux2014}/Dockerfile | 23 +-
pulsar-client-cpp/python/src/authentication.cc | 44 +-
pulsar-client-cpp/python/src/client.cc | 63 +-
pulsar-client-cpp/python/src/config.cc | 256 +++---
pulsar-client-cpp/python/src/consumer.cc | 81 +-
pulsar-client-cpp/python/src/cryptoKeyReader.cc | 2 +-
pulsar-client-cpp/python/src/enums.cc | 162 ++--
pulsar-client-cpp/python/src/exceptions.cc | 49 +-
pulsar-client-cpp/python/src/message.cc | 147 ++--
pulsar-client-cpp/python/src/producer.cc | 71 +-
pulsar-client-cpp/python/src/pulsar.cc | 4 +-
pulsar-client-cpp/python/src/reader.cc | 48 +-
pulsar-client-cpp/python/src/schema.cc | 10 +-
pulsar-client-cpp/python/src/utils.h | 3 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 3 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 83 +-
.../pulsar/common/util/RelativeTimeUtil.java | 12 +
.../PulsarProtobufNativeColumnDecoder.java | 15 +-
.../PulsarProtobufNativeRowDecoderFactory.java | 18 +-
.../sql/presto/decoder/protobufnative/TestMsg.java | 917 ++++++++++++++++-----
.../presto/decoder/protobufnative/TestMsg.proto | 2 +
.../protobufnative/TestProtobufNativeDecoder.java | 14 +
.../pulsar/websocket/stats/StatsBuckets.java | 2 +-
43 files changed, 1620 insertions(+), 811 deletions(-)
copy .github/workflows/{ci-cpp-build-centos7.yaml =>
ci-python-build-3.9-client.yaml} (88%)
copy pulsar-client-cpp/{docker-build-centos7.sh => docker-build-python3.9.sh}
(62%)
copy pulsar-client-cpp/docker/{ => manylinux1}/Dockerfile (97%)
rename pulsar-client-cpp/docker/{ => manylinux2014}/Dockerfile (96%)
