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 <[email protected]> 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(-)
