You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/07/12 23:14:21 UTC
[pulsar] 01/01: Merge remote-tracking branch 'apache/master' into structured-logging
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 <mm...@apache.org>
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(-)