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 6aeb408adacf53947ec708b6a0d2ac380d75f62b Merge: 9aa943b 3df9018 Author: Dave Fisher <[email protected]> AuthorDate: Mon Jan 31 08:36:00 2022 -0800 Merge branch 'master' of https://github.com/apache/pulsar conf/functions_worker.yml | 11 +- deployment/terraform-ansible/aws/ansible.cfg | 2 +- deployment/terraform-ansible/aws/instances.tf | 56 ++-- deployment/terraform-ansible/aws/keys.tf | 4 +- deployment/terraform-ansible/aws/network.tf | 50 +-- deployment/terraform-ansible/aws/provider.tf | 3 +- deployment/terraform-ansible/aws/security.tf | 8 +- deployment/terraform-ansible/aws/setup-disk.yaml | 14 +- deployment/terraform-ansible/aws/terraform.tfvars | 4 +- deployment/terraform-ansible/aws/variables.tf | 2 +- .../aws/{provider.tf => versions.tf} | 14 +- deployment/terraform-ansible/deploy-pulsar.yaml | 4 +- .../bookkeeper/mledger/ManagedLedgerConfig.java | 2 +- .../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 12 +- .../mledger/impl/NullLedgerOffloader.java | 2 +- .../apache/bookkeeper/mledger/util/Futures.java | 2 +- .../bookkeeper/mledger/impl/ManagedLedgerTest.java | 10 +- .../org/apache/pulsar/broker/PulsarService.java | 4 +- .../pulsar/broker/admin/v2/PersistentTopics.java | 6 +- .../pulsar/broker/service/AbstractTopic.java | 6 + .../pulsar/broker/service/BrokerService.java | 2 +- .../org/apache/pulsar/broker/service/Consumer.java | 37 ++- .../apache/pulsar/broker/service/ServerCnx.java | 23 +- ...istentStickyKeyDispatcherMultipleConsumers.java | 1 + .../broker/service/persistent/PersistentTopic.java | 18 +- .../pulsar/broker/web/PulsarWebResource.java | 85 +++-- .../BatchMessageWithBatchIndexLevelTest.java | 68 ++++ .../client/api/KeySharedSubscriptionTest.java | 128 +++++++ .../client/impl/TransactionEndToEndTest.java | 70 +++- .../client/api/AutoClusterFailoverBuilder.java | 128 +++++++ .../api/ControlledClusterFailoverBuilder.java | 73 ++++ .../pulsar/client/api/ServiceUrlProvider.java | 10 +- .../TransactionCoordinatorClientException.java | 15 - pulsar-client-cpp/docker-build-centos7.sh | 2 +- pulsar-client-cpp/docker/centos-7/Dockerfile | 7 + pulsar-client-cpp/tests/ConsumerTest.cc | 2 +- .../pulsar/client/impl/AutoClusterFailover.java | 368 +++++++++++++++++++++ .../client/impl/ControlledClusterFailover.java | 270 +++++++++++++++ .../pulsar/client/impl/PulsarClientImpl.java | 28 ++ .../oauth2/protocol/DefaultMetadataResolver.java | 6 + .../pulsar/client/impl/schema/AvroSchema.java | 9 +- .../pulsar/client/impl/schema/util/SchemaUtil.java | 2 +- .../client/impl/AutoClusterFailoverTest.java | 248 ++++++++++++++ .../client/impl/ControlledClusterFailoverTest.java | 130 ++++++++ .../pulsar/client/impl/schema/AvroSchemaTest.java | 23 +- .../policies/data/HierarchyTopicPolicies.java | 2 + .../pulsar/functions/worker/WorkerConfig.java | 16 + .../org/apache/pulsar/functions/worker/Worker.java | 3 +- .../pulsar/proxy/server/ProxyConfiguration.java | 14 + .../apache/pulsar/proxy/server/ProxyService.java | 10 +- .../pulsar/sql/presto/PulsarConnectorCache.java | 2 +- site2/docs/client-libraries-java.md | 39 ++- site2/docs/concepts-architecture-overview.md | 3 + site2/docs/functions-runtime.md | 2 +- site2/docs/functions-worker.md | 4 +- site2/docs/getting-started-standalone.md | 6 +- site2/docs/reference-configuration.md | 4 +- site2/docs/schema-evolution-compatibility.md | 2 +- site2/docs/schema-manage.md | 119 ++++++- site2/website-next/docs/functions-runtime.md | 2 +- site2/website-next/docs/functions-worker.md | 4 +- 61 files changed, 1985 insertions(+), 216 deletions(-)
