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(-)