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 107161f Bump version to 2.9.2-SNAPSHOT
new 048154c [Producer] Change the time units from ns to ms (#13057)
new 04455e3 [pulsar-client] Fix multi topic reader has message available
behavior (#13332)
new 3bef733 Fix NPE in cmdTopics (#13450)
new 4a8d6ef Fixes the NPE in system topics policies service (#13469)
new e429145 Fix dead loop in BacklogQuotaManager.dropBacklogForTimeLimit
(#13194) (#13249)
new 5ce1258 [Broker] Fix create the dynamic configuration resource if not
exist (#13420)
new 43df4db Fix semaphore and memory leak when chunks failed to enqueue
(#13454)
new 1a9f28b Optimize the debug log that affects performance, and unify
the style (#13498)
new 30acd13 [Broker] Remove check resource when delete failure domain
(#13421)
new 5637742 fix: bug when allAll bucket (#13467)
new fc3ab2e Fix reousrce leak when create producer failed (#13505)
new 3770191 Remove the unused junit depency in managed ledger (#13514)
new 008452b Add log error tracking for semaphore count leak (#12410)
new 32c6cdc Use PulsarByteBufAllocator to allocate buffer for chunks at
consumer side (#13536)
new c846c5f [Pulsar SQL] support protobuf/timestamp (#13287)
new 29533f1 Fix getting last message id from empty compact ledger (#13476)
new 5062677 Return message ID from compacted ledger while the compaction
cursor reach the end of the topic (#13533)
new 0e6bf54 [Security] Upgrade Log4j to 2.17.1 (#13552)
The 18 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:
buildtools/pom.xml | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 10 +-
managed-ledger/pom.xml | 9 -
.../bookkeeper/mledger/util/StatsBuckets.java | 2 +-
.../bookkeeper/mledger/util/TestStatsBuckets.java | 13 +
pom.xml | 2 +-
.../pulsar/broker/resources/ClusterResources.java | 12 +-
.../resources/DynamicConfigurationResources.java | 4 +-
.../pulsar/broker/admin/impl/BrokersBase.java | 3 +-
.../pulsar/broker/service/AbstractReplicator.java | 6 +-
.../pulsar/broker/service/BacklogQuotaManager.java | 28 +-
.../pulsar/broker/service/BrokerService.java | 11 +-
.../apache/pulsar/broker/service/ServerCnx.java | 5 +-
.../SystemTopicBasedTopicPoliciesService.java | 31 +-
.../apache/pulsar/compaction/CompactedTopic.java | 2 +
.../pulsar/compaction/CompactedTopicImpl.java | 21 +-
.../pulsar/broker/admin/AdminApiClusterTest.java | 98 +++
.../admin/AdminApiDynamicConfigurationsTest.java | 72 ++
.../broker/service/BacklogQuotaManagerTest.java | 48 ++
.../broker/service/ExclusiveProducerTest.java | 28 +
.../broker/service/TopicTerminationTest.java | 28 +
.../pulsar/client/impl/MessageChunkingTest.java | 43 +
.../pulsar/client/impl/MultiTopicsReaderTest.java | 67 ++
.../pulsar/compaction/CompactedTopicTest.java | 86 +-
.../org/apache/pulsar/admin/cli/CmdTopics.java | 4 +
.../apache/pulsar/client/impl/ConsumerImpl.java | 3 +-
.../client/impl/MultiTopicsConsumerImpl.java | 3 +
.../pulsar/client/impl/MultiTopicsReaderImpl.java | 2 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 83 +-
.../pulsar/common/util/RelativeTimeUtil.java | 12 +
.../pulsar/functions/windowing/WindowManager.java | 13 +-
.../triggers/WatermarkTimeTriggerPolicy.java | 14 +-
.../functions/worker/FunctionMetaDataManager.java | 5 +-
.../pulsar/sql/presto/PulsarRecordCursor.java | 4 +-
.../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 +-
40 files changed, 1444 insertions(+), 298 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiClusterTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiDynamicConfigurationsTest.java
