This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch structured-logging in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 8d43e4b2b6ab3ecd56ed71271b4b79290ceb6c3c Merge: 3b25fdcb39d de343c89801 Author: Matteo Merli <[email protected]> AuthorDate: Tue Jul 12 16:14:04 2022 -0700 Merge remote-tracking branch 'apache/master' into structured-logging build/run_unit_group.sh | 2 +- conf/broker.conf | 10 ++ distribution/server/src/assemble/LICENSE.bin.txt | 16 +- pom.xml | 8 +- .../apache/pulsar/broker/ServiceConfiguration.java | 17 ++ .../authorization/AuthorizationProvider.java | 1 + .../pulsar/broker/admin/impl/NamespacesBase.java | 5 - .../apache/pulsar/broker/admin/v1/Namespaces.java | 18 +- .../apache/pulsar/broker/admin/v2/Namespaces.java | 14 +- .../loadbalance/ModularLoadManagerStrategy.java | 14 +- .../impl/LeastResourceUsageWithWeight.java | 165 ++++++++++++++++++ .../loadbalance/impl/LinuxBrokerHostUsageImpl.java | 2 +- .../loadbalance/impl/ModularLoadManagerImpl.java | 2 +- .../apache/pulsar/broker/service/ServerCnx.java | 5 +- .../pulsar/broker/service/TopicListService.java | 2 +- .../broker/service/persistent/PersistentTopic.java | 9 +- .../service/schema/SchemaRegistryServiceImpl.java | 1 + .../pulsar/broker/admin/AdminApiSchemaTest.java | 18 +- .../broker/admin/AdminApiSchemaWithAuthTest.java | 21 ++- .../ModularLoadManagerStrategyTest.java | 70 ++++++++ .../pulsar/broker/service/MessageTTLTest.java | 33 ++-- .../PersistentDispatcherFailoverConsumerTest.java | 36 ++-- .../broker/service/PersistentFailoverE2ETest.java | 31 ++-- ...herFailoverConsumerStreamingDispatcherTest.java | 2 +- .../pendingack/PendingAckPersistentTest.java | 58 +++++++ .../pulsar/client/api/MultiTopicsConsumerTest.java | 32 ++-- .../apache/pulsar/client/api/SimpleSchemaTest.java | 44 ++--- .../client/impl/TransactionEndToEndTest.java | 42 ++++- .../java/org/apache/pulsar/schema/SchemaTest.java | 9 +- .../pulsar/client/admin/internal/SchemasImpl.java | 1 + .../PulsarClientImplementationBinding.java | 3 +- .../apache/pulsar/common/schema/SchemaInfo.java | 13 +- pulsar-client-tools/pom.xml | 15 ++ .../apache/pulsar/client/impl/ProducerBase.java | 5 - .../PulsarClientImplementationBindingImpl.java | 6 +- .../impl/schema/RecordSchemaBuilderImpl.java | 1 + .../pulsar/client/impl/schema/SchemaInfoTest.java | 15 +- .../pulsar/client/impl/schema/SchemaInfoImpl.java | 5 + .../org/apache/pulsar/common/topics/TopicList.java | 7 + .../util/collections/SegmentedLongArray.java | 128 ++++++++++++++ .../util/collections/TripleLongPriorityQueue.java | 187 ++++++++++----------- .../util/collections/SegmentedLongArrayTest.java | 103 ++++++++++++ .../collections/TripleLongPriorityQueueTest.java | 41 ++++- .../org/apache/pulsar/functions/api/Context.java | 2 + pulsar-sql/pom.xml | 66 -------- pulsar-sql/presto-distribution/LICENSE | 28 +-- pulsar-sql/presto-distribution/pom.xml | 9 - site2/docs/admin-api-brokers.md | 36 ++-- site2/docs/administration-load-balance.md | 20 ++- site2/docs/administration-metadata-store.md | 120 +++++++++++++ site2/docs/assets/OverloadShedder.png | Bin 44951 -> 0 bytes site2/docs/assets/ThresholdShedder.png | Bin 56518 -> 0 bytes site2/docs/assets/UniformLoadShedder.png | Bin 50894 -> 0 bytes .../assets/shedding-strategy-overloadshedder.svg | 1 + .../assets/shedding-strategy-thresholdshedder.svg | 1 + .../shedding-strategy-uniformLoadshedder.svg | 1 + site2/docs/client-libraries-cgo.md | 2 +- site2/docs/client-libraries-cpp.md | 2 +- site2/docs/client-libraries-java.md | 2 +- site2/docs/client-libraries-websocket.md | 2 +- site2/docs/concepts-messaging.md | 4 +- site2/docs/concepts-multi-tenancy.md | 2 +- site2/docs/deploy-aws.md | 2 +- site2/docs/deploy-bare-metal-multi-cluster.md | 2 +- site2/docs/deploy-bare-metal.md | 4 +- site2/docs/functions-concepts.md | 10 +- site2/docs/functions-overview.md | 2 +- site2/docs/functions-runtime.md | 6 +- site2/docs/functions-worker-temp-file-path.md | 4 +- site2/docs/getting-started-docker.md | 3 +- site2/docs/getting-started-helm.md | 18 +- site2/docs/getting-started-standalone.md | 28 ++- site2/docs/io-cdc.md | 4 +- site2/docs/io-develop.md | 2 +- site2/docs/io-quickstart.md | 6 +- site2/docs/reference-cli-tools.md | 2 +- site2/docs/reference-configuration.md | 3 +- site2/docs/security-authorization.md | 4 +- site2/docs/security-jwt.md | 67 ++++---- site2/docs/security-tls-keystore.md | 4 +- site2/docs/security-tls-transport.md | 4 +- site2/docs/sql-deployment-configurations.md | 2 +- site2/docs/sql-overview.md | 2 +- site2/docs/tiered-storage-overview.md | 12 +- .../blog/2022-07-12-Apache-Pulsar-2-10-1.md | 74 ++++++++ site2/website/sidebars.json | 3 +- .../version-2.10.0/admin-api-brokers.md | 2 +- .../version-2.10.0/administration-load-balance.md | 20 ++- .../administration-pulsar-manager.md | 4 +- .../version-2.10.0/client-libraries-cpp.md | 2 +- .../version-2.10.0/client-libraries-java.md | 4 +- .../concepts-architecture-overview.md | 2 +- .../version-2.10.0/concepts-messaging.md | 2 +- .../version-2.10.0/cookbooks-compaction.md | 2 +- .../version-2.10.0/cookbooks-non-persistent.md | 2 +- .../versioned_docs/version-2.10.0/deploy-aws.md | 2 +- .../deploy-bare-metal-multi-cluster.md | 2 +- .../version-2.10.0/deploy-bare-metal.md | 4 +- .../version-2.10.0/functions-develop.md | 2 +- .../version-2.10.0/functions-overview.md | 2 +- .../version-2.10.0/functions-worker.md | 2 +- .../versioned_docs/version-2.10.0/io-cdc.md | 4 +- .../versioned_docs/version-2.10.0/io-develop.md | 2 +- .../version-2.10.0/io-kafka-source.md | 2 +- .../versioned_docs/version-2.10.0/io-overview.md | 2 +- .../versioned_docs/version-2.10.0/io-quickstart.md | 6 +- .../version-2.10.0/performance-pulsar-perf.md | 4 +- .../version-2.10.0/reference-cli-tools.md | 2 +- .../versioned_docs/version-2.10.0/schema-manage.md | 2 +- .../version-2.10.0/security-athenz.md | 2 +- .../version-2.10.0/security-authorization.md | 2 +- .../versioned_docs/version-2.10.0/security-jwt.md | 22 ++- .../version-2.10.0/security-tls-authentication.md | 2 +- .../version-2.10.0/security-tls-keystore.md | 4 +- .../version-2.10.0/security-tls-transport.md | 2 +- .../sql-deployment-configurations.md | 2 +- .../versioned_docs/version-2.10.0/sql-overview.md | 2 +- .../version-2.10.0/tiered-storage-overview.md | 6 +- .../version-2.10.1/performance-pulsar-perf.md | 3 +- .../versioned_docs/version-2.10.1/security-jwt.md | 22 ++- .../versioned_docs/version-2.8.0/security-jwt.md | 12 +- .../versioned_docs/version-2.8.1/security-jwt.md | 12 +- .../versioned_docs/version-2.8.2/security-jwt.md | 12 +- .../versioned_docs/version-2.8.3/security-jwt.md | 12 +- .../versioned_docs/version-2.9.0/security-jwt.md | 12 +- .../versioned_docs/version-2.9.1/security-jwt.md | 12 +- .../versioned_docs/version-2.9.2/security-jwt.md | 12 +- src/assembly-source-package.xml | 2 + .../java/org/apache/zookeeper/MockZooKeeper.java | 159 ++++++++++-------- tests/docker-images/java-test-functions/pom.xml | 1 - .../tests/integration/cli/AdminMultiHostTest.java | 3 +- .../pulsar/tests/integration/cli/CLITest.java | 2 +- .../integration/cli/SchemaUpdateStrategyTest.java | 1 + .../integration/containers/ChaosContainer.java | 2 +- .../integration/containers/PulsarContainer.java | 2 +- .../integration/functions/PulsarFunctionsTest.java | 13 +- .../integration/functions/PulsarStateTest.java | 1 + .../io/PulsarGenericObjectSinkTest.java | 45 ++--- .../tests/integration/io/PulsarIOTestBase.java | 4 +- .../tests/integration/io/PulsarIOTestRunner.java | 7 +- .../io/sinks/ElasticSearchSinkTester.java | 2 +- .../integration/io/sinks/KafkaSinkTester.java | 1 + .../integration/io/sinks/KinesisSinkTester.java | 4 +- .../tests/integration/io/sinks/SinkTester.java | 4 +- .../io/sources/AvroKafkaSourceTest.java | 8 +- .../tests/integration/io/sources/SourceTester.java | 1 + .../debezium/DebeziumMongoDbSourceTester.java | 8 +- .../debezium/DebeziumMySqlSourceTester.java | 8 +- .../debezium/PulsarIODebeziumSourceRunner.java | 2 +- .../tests/integration/offload/TestBaseOffload.java | 2 +- .../integration/presto/StockProtoMessage.java | 2 + .../tests/integration/presto/TestBasicPresto.java | 13 +- .../presto/TestPrestoQueryTieredStorage.java | 4 +- .../integration/presto/TestPulsarSQLBase.java | 8 +- .../tests/integration/schema/SchemaTest.java | 2 +- .../tests/integration/semantics/SemanticsTest.java | 4 +- .../integration/topologies/PulsarCluster.java | 2 +- .../integration/topologies/PulsarClusterSpec.java | 3 +- .../integration/SimpleProducerConsumerTest.java | 6 +- .../integration/SimpleProducerConsumerTest.java | 6 +- .../integration/SimpleProducerConsumerTest.java | 4 +- 161 files changed, 1626 insertions(+), 724 deletions(-)
