You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/03/09 05:19:41 UTC
[pulsar] branch branch-2.8 updated (8e19649 -> 93bec02)
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 8e19649 [branch-2.8] Remove awaitility duplicated declaration warning (#14514)
add 7046266 Fixing get functions for output topic and serde classname (#14103)
add 956f023 Fix can't read the latest message of the compacted topic (#14449)
add c7cf50a Validate rack name (#14336)
add e60838d [pulsar-broker] Fix avg-messagePerEntry metrics for consumer (#14330)
add f2ddcbc fix npe in ManagedLedgerImpl (#14481)
add b1410a5 [pulsar-io] throw exceptions when kafka offset backing store failed to start (#14491)
add fe90b2c [Functions] Pass configured metricsPort to k8s runtime (#14502)
add 10b2f34 [Flaky-test]: AdminApiTest.testNamespaceSplitBundleConcurrent (#14565)
add 669ce98 [C++] Fix wrong unit of Access Token Response's `expires_in` field (#14554)
add 93bec02 [Broker] Fixed wrong behaviour caused by not cleaning up topic policy service state. (#14503)
No new revisions were added by this update.
Summary of changes:
conf/functions_worker.yml | 1 +
.../apache/bookkeeper/mledger/ManagedCursor.java | 6 ++-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 7 +--
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 4 +-
.../mledger/impl/ManagedCursorContainerTest.java | 3 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 6 +--
.../mledger/impl/NonDurableCursorTest.java | 2 +-
.../org/apache/pulsar/broker/admin/v2/Bookies.java | 15 ++++++
.../org/apache/pulsar/broker/service/Consumer.java | 2 +-
.../SystemTopicBasedTopicPoliciesService.java | 39 ++++++++-------
.../service/persistent/PersistentSubscription.java | 10 +++-
.../apache/pulsar/broker/admin/AdminApiTest.java | 7 +--
.../apache/pulsar/broker/admin/BookiesApiTest.java | 58 +++++++++++++++++++++-
.../pulsar/broker/service/PersistentTopicTest.java | 3 +-
.../pulsar/compaction/CompactedTopicTest.java | 50 +++++++++++++++++++
pulsar-client-cpp/lib/auth/AuthOauth2.cc | 15 +-----
pulsar-client-cpp/lib/auth/AuthOauth2.h | 5 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 3 +-
.../instance/src/main/python/contextimpl.py | 4 +-
.../runtime/kubernetes/KubernetesRuntime.java | 18 +++++--
.../kubernetes/KubernetesRuntimeFactory.java | 7 ++-
.../runtime/kubernetes/KubernetesRuntimeTest.java | 51 +++++++++++++++++++
.../functions/worker/FunctionsStatsGenerator.java | 5 +-
.../io/kafka/connect/PulsarOffsetBackingStore.java | 21 +++++---
24 files changed, 274 insertions(+), 68 deletions(-)