You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by wa...@apache.org on 2022/03/15 16:05:03 UTC
[pulsar] 07/13: Merge branch 'master' of https://github.com/apache/pulsar
This is an automated email from the ASF dual-hosted git repository.
wave pushed a commit to branch dave2wave-branch-14693
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 30efdd8c7793d83b72e441fb25f619a344fdfa19
Merge: 735df92 992dfbd
Author: Dave Fisher <da...@datastax.com>
AuthorDate: Thu Feb 24 09:05:16 2022 -0800
Merge branch 'master' of https://github.com/apache/pulsar
.asf.yaml | 2 +-
.github/workflows/ci-stale-issue-pr.yaml | 16 +
.../apache/pulsar/broker/ServiceConfiguration.java | 4 +
.../org/apache/pulsar/broker/PulsarService.java | 3 +-
.../pulsar/broker/service/AbstractTopic.java | 28 ++
.../pulsar/broker/service/BrokerService.java | 3 +
.../service/persistent/DispatchRateLimiter.java | 3 +
.../broker/service/persistent/PersistentTopic.java | 22 +-
.../buffer/impl/TopicTransactionBuffer.java | 1 -
.../org/apache/pulsar/client/api/RawReader.java | 2 +-
.../apache/pulsar/client/impl/RawReaderImpl.java | 2 +
.../pulsar/broker/transaction/TransactionTest.java | 25 ++
.../apache/pulsar/client/impl/TableViewTest.java | 57 ++++
.../org/apache/pulsar/admin/cli/CmdBookies.java | 17 +-
.../apache/pulsar/client/impl/TableViewImpl.java | 3 +-
.../client/impl/conf/ClientConfigurationData.java | 4 +-
.../policies/data/HierarchyTopicPolicies.java | 2 +
.../examples/userMetricsFunc/userMetricsFunc.go | 44 +++
pulsar-function-go/pf/context.go | 20 ++
pulsar-function-go/pf/instance.go | 51 +++-
pulsar-function-go/pf/stats.go | 21 +-
pulsar-function-go/pf/stats_test.go | 43 +++
.../impl/MLTransactionMetadataStore.java | 328 ++++++++++++---------
site2/docs/administration-isolation.md | 8 +-
site2/docs/functions-develop.md | 17 +-
site2/docs/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.4.1/io-debug.md | 10 +-
.../versioned_docs/version-2.4.2/io-debug.md | 10 +-
.../versioned_docs/version-2.5.0/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.5.1/io-debug.md | 10 +-
.../versioned_docs/version-2.5.2/io-debug.md | 10 +-
.../versioned_docs/version-2.6.0/io-debug.md | 10 +-
.../versioned_docs/version-2.6.0/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.6.1/io-debug.md | 10 +-
.../versioned_docs/version-2.6.1/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.6.2/io-debug.md | 10 +-
.../versioned_docs/version-2.6.2/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.6.3/io-debug.md | 10 +-
.../versioned_docs/version-2.6.3/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.6.4/io-debug.md | 10 +-
.../versioned_docs/version-2.6.4/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.7.0/io-debug.md | 10 +-
.../versioned_docs/version-2.7.0/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.7.1/io-debug.md | 10 +-
.../versioned_docs/version-2.7.1/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.7.2/io-debug.md | 10 +-
.../versioned_docs/version-2.7.2/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.7.3/io-debug.md | 10 +-
.../versioned_docs/version-2.7.3/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.7.4/io-debug.md | 10 +-
.../versioned_docs/version-2.7.4/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.8.0/io-debug.md | 10 +-
.../versioned_docs/version-2.8.0/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.8.1/io-debug.md | 10 +-
.../versioned_docs/version-2.8.1/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.8.2/io-debug.md | 10 +-
.../versioned_docs/version-2.8.2/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.9.0/io-debug.md | 10 +-
.../versioned_docs/version-2.9.0/io-mongo-sink.md | 3 +-
.../versioned_docs/version-2.9.1/io-debug.md | 10 +-
.../versioned_docs/version-2.9.1/io-mongo-sink.md | 3 +-
.../tests/integration/cli/tenant/TenantTest.java | 122 ++++++++
.../integration/topologies/PulsarCluster.java | 3 -
.../integration/topologies/PulsarTestBase.java | 9 +
.../integration/src/test/resources/pulsar-cli.xml | 1 +
65 files changed, 797 insertions(+), 305 deletions(-)