This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch lp-functions-proto
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from b81edb05924 [improve][fn] Fix LightProto equality issues in worker and
test classes
add 701e1d8e9ab [fix][ml] Fix concurrent cursor properties update race
(#25434)
add 0f1d79046c9 [feat][monitor] Add custom topic metric labels to
OpenTelemetry metrics attributes (#25306)
add 7c26e12a29b [improve][test] Suppress deprecation compile warnings in
test code (#25432)
add f2dbcafc3d1 [improve][test] Fix cast, static, removal, and varargs
compile warnings in test code (#25428)
add 7690830e3b0 [improve][test] Fix rawtypes compile warnings in test code
(#25430)
new cffb9b13f26 Merge remote-tracking branch 'apache/master' into
lp-functions-proto
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../pulsar/client/TlsProducerConsumerBase.java | 1 +
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 +-
.../impl/InflightReadsLimiterIntegrationTest.java | 4 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 8 +-
.../mledger/impl/ManagedLedgerBkTest.java | 14 +-
.../impl/ManagedLedgerInfoMetadataTest.java | 1 +
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 14 +-
.../mledger/impl/OffloadPrefixReadTest.java | 6 +-
.../impl/cache/InflightReadsLimiterTest.java | 5 +-
.../org/apache/bookkeeper/test/ZooKeeperUtil.java | 2 +-
...uthenticationProviderOpenIDIntegrationTest.java | 2 +
.../oidc/AuthenticationProviderOpenIDTest.java | 12 ++
.../authentication/SaslAuthenticateTest.java | 2 +
.../AuthenticationProviderListTest.java | 7 +
.../AuthenticationProviderTokenTest.java | 19 ++
.../OneStageAuthenticationStateTest.java | 1 +
.../MultiRolesTokenAuthorizationProviderTest.java | 8 +
.../broker/resources/TopicResourcesTest.java | 1 +
.../stats/prometheus/PrometheusMetricsClient.java | 1 +
.../broker/service/PersistentTopicAttributes.java | 133 +++++++++++-
.../broker/service/persistent/PersistentTopic.java | 2 +-
.../broker/stats/OpenTelemetryTopicStats.java | 98 +++++----
.../CustomizedManagedLedgerStorageForTest.java | 1 +
.../mledger/impl/CustomizedManagedLedgerTest.java | 1 +
.../impl/MangedLedgerInterceptorImpl2Test.java | 4 +-
.../NonEntryCacheKeySharedSubscriptionV30Test.java | 21 +-
.../pulsar/MockTokenAuthenticationProvider.java | 3 +
.../org/apache/pulsar/PulsarBrokerStarterTest.java | 5 +-
.../pulsar/PulsarClusterMetadataTeardownTest.java | 2 +-
.../apache/pulsar/PulsarVersionStarterTest.java | 2 +-
.../pulsar/broker/BrokerAdditionalServletTest.java | 1 +
.../org/apache/pulsar/broker/ConfigHelper.java | 1 +
.../pulsar/broker/EmbeddedPulsarCluster.java | 1 +
.../LedgerLostAndSkipNonRecoverableTest.java | 11 +-
...ameAuthParamsLookupAutoClusterFailoverTest.java | 1 +
.../apache/pulsar/broker/admin/AdminApi2Test.java | 20 +-
.../broker/admin/AdminApiDelayedDeliveryTest.java | 1 +
.../broker/admin/AdminApiHealthCheckTest.java | 1 +
.../admin/AdminApiMaxUnackedMessagesTest.java | 13 +-
.../broker/admin/AdminApiMultiBrokersTest.java | 2 +
.../pulsar/broker/admin/AdminApiOffloadTest.java | 3 +
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 4 +
.../pulsar/broker/admin/AdminApiSchemaTest.java | 6 +-
.../AdminApiSchemaValidationEnforcedTest.java | 8 +-
.../broker/admin/AdminApiSchemaWithAuthTest.java | 1 +
.../apache/pulsar/broker/admin/AdminApiTest.java | 10 +
.../org/apache/pulsar/broker/admin/AdminTest.java | 9 +-
.../admin/AnalyzeBacklogSubscriptionTest.java | 14 +-
.../broker/admin/CreateSubscriptionTest.java | 8 +-
.../broker/admin/GetPartitionMetadataTest.java | 1 +
.../broker/admin/MaxUnackedMessagesTest.java | 6 +
.../pulsar/broker/admin/NamespaceAuthZTest.java | 1 +
.../apache/pulsar/broker/admin/NamespacesTest.java | 4 +
.../pulsar/broker/admin/PersistentTopicsTest.java | 3 +
.../pulsar/broker/admin/TopicMessageTTLTest.java | 7 +-
.../broker/admin/TopicPoliciesDisableTest.java | 12 ++
.../pulsar/broker/admin/TopicPoliciesTest.java | 41 ++--
.../apache/pulsar/broker/admin/TopicsAuthTest.java | 4 +
.../v3/AdminApiTransactionMultiBrokerTest.java | 1 +
.../broker/admin/v3/AdminApiTransactionTest.java | 2 +-
.../broker/auth/AuthenticationServiceTest.java | 15 ++
.../broker/auth/AuthorizationWithAuthDataTest.java | 1 +
.../pulsar/broker/auth/MockAuthentication.java | 2 +
.../broker/auth/MockAuthenticationProvider.java | 2 +
.../auth/MockMultiStageAuthenticationState.java | 2 +
.../auth/MockMutableAuthenticationState.java | 2 +
.../broker/auth/MockOIDCIdentityProvider.java | 1 +
.../broker/auth/MockedPulsarServiceBaseTest.java | 5 +-
.../AbstractBrokerEntryCacheMultiBrokerTest.java | 1 +
.../cache/BrokerEntryCacheRollingRestartTest.java | 1 +
.../pulsar/broker/cache/BrokerEntryCacheTest.java | 5 +
.../cache/MinimumBacklogCacheStrategyTest.java | 1 +
.../bucket/BucketDelayedDeliveryTrackerTest.java | 2 +
.../BrokerInterceptorWithClassLoaderTest.java | 1 +
.../broker/intercept/CounterBrokerInterceptor.java | 2 +
.../intercept/ExceptionsBrokerInterceptorTest.java | 4 +-
.../ModularLoadManagerStrategyTest.java | 10 +-
.../loadbalance/SimpleLoadManagerImplTest.java | 1 +
.../ExtensibleLoadManagerImplBaseTest.java | 1 +
.../extensions/ExtensibleLoadManagerImplTest.java | 5 +
.../channel/ServiceUnitStateChannelTest.java | 11 +-
.../extensions/data/BrokerLoadDataTest.java | 2 +
.../extensions/models/TopKBundlesTest.java | 6 +-
.../reporter/BrokerLoadDataReporterTest.java | 1 +
.../reporter/TopBundleLoadDataReporterTest.java | 3 +-
.../extensions/scheduler/SplitSchedulerTest.java | 4 +-
.../DefaultNamespaceBundleSplitStrategyTest.java | 2 +-
.../strategy/LeastResourceUsageWithWeightTest.java | 1 +
.../impl/ModularLoadManagerImplTest.java | 4 +-
.../broker/namespace/NamespaceServiceTest.java | 7 +
.../broker/namespace/OwnershipCacheTest.java | 1 +
.../broker/service/AbstractReplicatorTest.java | 1 +
.../BacklogQuotaManagerConfigurationTest.java | 3 +
.../broker/service/BacklogQuotaManagerTest.java | 24 +++
.../broker/service/BrokerBkEnsemblesTest.java | 7 +
.../broker/service/BrokerBookieIsolationTest.java | 4 +
.../broker/service/BrokerEntryMetadataE2ETest.java | 2 +
.../pulsar/broker/service/BrokerServiceTest.java | 4 +
.../service/BrokerServiceThrottlingTest.java | 3 +
.../pulsar/broker/service/BusyWaitServiceTest.java | 1 +
.../broker/service/ClusterMigrationTest.java | 6 +
.../broker/service/InactiveTopicDeleteTest.java | 4 +
.../broker/service/OneWayReplicatorTest.java | 10 +-
.../broker/service/OpportunisticStripingTest.java | 1 +
.../pulsar/broker/service/PeerReplicatorTest.java | 2 +
.../PersistentDispatcherFailoverConsumerTest.java | 1 +
.../broker/service/PersistentTopicE2ETest.java | 1 +
.../pulsar/broker/service/PersistentTopicTest.java | 3 +-
.../PublishRateLimiterOverconsumingTest.java | 1 +
.../pulsar/broker/service/RackAwareTest.java | 1 +
.../broker/service/ReplicatedSubscriptionTest.java | 15 +-
.../broker/service/ReplicatorGlobalNSTest.java | 1 +
.../broker/service/ReplicatorRateLimiterTest.java | 7 +
.../service/ReplicatorRemoveClusterTest.java | 1 +
.../pulsar/broker/service/ReplicatorTest.java | 11 +-
.../pulsar/broker/service/ReplicatorTestBase.java | 5 +
.../pulsar/broker/service/ServerCnxTest.java | 8 +
.../pulsar/broker/service/SharedPulsarCluster.java | 1 +
.../SystemTopicBasedTopicPoliciesServiceTest.java | 1 +
.../apache/pulsar/broker/service/TopicGCTest.java | 2 +-
.../pulsar/broker/service/TopicOwnerTest.java | 3 +-
.../TransactionalReplicateSubscriptionTest.java | 4 +-
.../service/persistent/DelayedDeliveryTest.java | 3 +
...tDispatcherMultipleConsumersReadLimitsTest.java | 1 +
.../PersistentReplicatorInflightTaskTest.java | 2 +-
.../persistent/PersistentSubscriptionTest.java | 1 +
.../PersistentTopicProtectedMethodsTest.java | 2 +-
.../service/persistent/PersistentTopicTest.java | 8 +-
.../service/persistent/TopicDuplicationTest.java | 6 +
.../schema/validator/SchemaDataValidatorTest.java | 1 +
.../stats/AuthenticatedConsumerStatsTest.java | 1 +
.../pulsar/broker/stats/ConsumerStatsTest.java | 1 +
.../broker/stats/MetadataStoreStatsTest.java | 1 +
.../OpenTelemetryAuthenticationStatsTest.java | 1 +
.../stats/OpenTelemetryCustomLabelsTest.java | 235 +++++++++++++++++++++
.../broker/stats/PrometheusMetricsLabelsTest.java | 1 +
.../pulsar/broker/stats/PrometheusMetricsTest.java | 4 +
.../stats/TransactionBatchWriterMetricsTest.java | 1 +
.../systopic/PartitionedSystemTopicTest.java | 8 +-
.../broker/testcontext/PulsarTestContext.java | 1 +
.../apache/pulsar/broker/tools/BrokerToolTest.java | 2 +-
...thenticatedTransactionProducerConsumerTest.java | 1 +
.../SegmentAbortedTxnProcessorTest.java | 7 +-
.../TopicTransactionBufferRecoverTest.java | 10 +-
.../broker/transaction/TransactionConsumeTest.java | 2 +-
.../pulsar/broker/transaction/TransactionTest.java | 23 +-
.../broker/transaction/TransactionTestBase.java | 1 +
.../buffer/TopicTransactionBufferTest.java | 1 +
.../buffer/TransactionBufferCloseTest.java | 1 +
.../buffer/TransactionStablePositionTest.java | 1 +
.../TransactionMetaStoreAssignmentTest.java | 1 +
.../pendingack/impl/MLPendingAckStoreTest.java | 2 +-
.../AdditionalServletWithPulsarServiceTest.java | 1 +
.../api/AuthenticatedProducerConsumerTest.java | 9 +
.../AuthenticationTlsHostnameVerificationTest.java | 1 +
.../api/AuthorizationProducerConsumerTest.java | 2 +
.../pulsar/client/api/BrokerServiceLookupTest.java | 1 +
.../client/api/ClientDeduplicationFailureTest.java | 1 +
.../apache/pulsar/client/api/ClientErrorsTest.java | 1 +
.../pulsar/client/api/ConsumerCleanupTest.java | 1 +
.../pulsar/client/api/DeadLetterTopicTest.java | 2 +
.../apache/pulsar/client/api/InterceptorsTest.java | 3 +
.../MultiRolesTokenAuthorizationProviderTest.java | 2 +
.../pulsar/client/api/MultiTopicsConsumerTest.java | 1 +
.../client/api/MutualAuthenticationTest.java | 3 +
.../pulsar/client/api/NonPersistentTopicTest.java | 1 +
.../api/PartitionedProducerConsumerTest.java | 2 +
...icWatcherBackPressureMultipleConsumersTest.java | 1 +
.../pulsar/client/api/ProducerConsumerBase.java | 2 +-
.../pulsar/client/api/ProducerQueueSizeTest.java | 1 +
.../pulsar/client/api/ProxyProtocolTest.java | 2 +
...MultiListenersWithInternalListenerNameTest.java | 1 +
.../apache/pulsar/client/api/RetryTopicTest.java | 1 +
.../pulsar/client/api/ServiceUrlProviderTest.java | 2 +
.../client/api/SimpleProducerConsumerStatTest.java | 6 +
.../client/api/SimpleProducerConsumerTest.java | 2 +
.../apache/pulsar/client/api/SimpleSchemaTest.java | 1 +
.../pulsar/client/api/TlsProducerConsumerBase.java | 1 +
.../pulsar/client/api/TlsProducerConsumerTest.java | 4 +
.../TokenAuthenticatedProducerConsumerTest.java | 2 +
.../api/TokenExpirationProduceConsumerTest.java | 4 +
...kenOauth2AuthenticatedProducerConsumerTest.java | 2 +
.../apache/pulsar/client/api/TopicReaderTest.java | 1 +
.../pulsar/client/api/UnloadSubscriptionTest.java | 1 +
.../client/impl/AdminApiKeyStoreTlsAuthTest.java | 1 +
.../impl/AutoCloseUselessClientConSupports.java | 1 +
...eUselessClientConTopicsPatternConsumerTest.java | 1 +
.../client/impl/BrokerClientIntegrationTest.java | 4 +
.../apache/pulsar/client/impl/ClientCnxTest.java | 1 +
.../apache/pulsar/client/impl/ConsumerAckTest.java | 1 +
...eyStoreTlsProducerConsumerTestWithAuthTest.java | 2 +
...toreTlsProducerConsumerTestWithoutAuthTest.java | 1 +
.../apache/pulsar/client/impl/LookupRetryTest.java | 1 +
.../pulsar/client/impl/MessageChunkingTest.java | 1 +
.../pulsar/client/impl/MessageParserTest.java | 1 +
.../impl/PatternTopicsConsumerImplAuthTest.java | 2 +
.../client/impl/PulsarMultiHostClientTest.java | 3 +
.../pulsar/client/impl/SchemaDeleteTest.java | 1 +
.../apache/pulsar/client/impl/TableViewTest.java | 7 +
.../pulsar/client/impl/TopicsConsumerImplTest.java | 1 +
.../client/impl/TransactionEndToEndTest.java | 1 +
.../common/naming/ServiceConfigurationTest.java | 2 +
.../pulsar/compaction/CompactedTopicTest.java | 1 +
.../pulsar/compaction/CompactionRetentionTest.java | 1 +
.../apache/pulsar/compaction/CompactionTest.java | 1 +
.../compaction/GetLastMessageIdCompactedTest.java | 8 +
.../compaction/ServiceUnitStateCompactionTest.java | 3 +
.../pulsar/compaction/StrategicCompactionTest.java | 1 +
.../worker/PulsarFunctionE2ESecurityTest.java | 2 +
.../worker/PulsarFunctionLocalRunTest.java | 3 +
.../worker/PulsarFunctionPublishTest.java | 4 +
.../functions/worker/PulsarFunctionTlsTest.java | 2 +
.../worker/PulsarWorkerAssignmentTest.java | 1 +
.../apache/pulsar/io/AbstractPulsarE2ETest.java | 2 +
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 2 +
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 3 +
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 3 +
.../java/org/apache/pulsar/schema/SchemaTest.java | 1 +
...hemaTypeCompatibilityCheckOnTopicLevelTest.java | 1 +
.../pulsar/security/MockedPulsarStandalone.java | 3 +
.../utils/auth/tokens/TokensCliUtilsTest.java | 2 +
.../proxy/MockAuthenticationProvider.java | 2 +
.../websocket/proxy/ProxyPublishConsumeTest.java | 2 +-
.../pulsar/websocket/proxy/ProxyRoleAuthTest.java | 1 +
.../admin/internal/PulsarAdminBuilderImplTest.java | 2 +
.../pulsar/admin/cli/PulsarAdminToolTest.java | 6 +-
.../client/cli/PulsarClientToolForceBatchNum.java | 1 +
.../org/apache/pulsar/admin/cli/TestCmdTopics.java | 6 +
.../org/apache/pulsar/admin/cli/TestRunMain.java | 2 +-
.../pulsar/client/api/MessageRouterTest.java | 1 +
.../client/impl/BatchMessageContainerImplTest.java | 2 +-
.../pulsar/client/impl/BatchMessageIdImplTest.java | 1 +
.../apache/pulsar/client/impl/BuildersTest.java | 5 +-
.../pulsar/client/impl/ClientBuilderImplTest.java | 2 +
.../apache/pulsar/client/impl/ClientCnxTest.java | 4 +-
.../client/impl/ClientInitializationTest.java | 1 +
.../pulsar/client/impl/ConsumerImplTest.java | 3 +
.../pulsar/client/impl/MessageIdCompareToTest.java | 2 +
.../apache/pulsar/client/impl/MessageImplTest.java | 18 +-
.../client/impl/MultiTopicsConsumerImplTest.java | 3 +
.../client/impl/PartitionedProducerImplTest.java | 24 ++-
.../impl/PatternConsumerUpdateQueueTest.java | 7 +-
.../client/impl/ProducerBuilderImplTest.java | 3 +
.../client/impl/TableViewBuilderImplTest.java | 12 +-
.../pulsar/client/impl/TableViewImplTest.java | 2 +-
.../pulsar/client/impl/TopicMessageIdImplTest.java | 1 +
.../client/impl/TypedMessageBuilderImplTest.java | 50 +++--
.../client/impl/auth/AuthenticationTokenTest.java | 1 +
.../client/impl/auth/MockAuthentication.java | 2 +
.../MockEncodedAuthenticationParameterSupport.java | 2 +
.../oauth2/AuthenticationFactoryOAuth2Test.java | 1 +
.../impl/conf/ConfigurationDataUtilsTest.java | 6 +-
.../client/impl/schema/KeyValueSchemaInfoTest.java | 4 +-
.../client/impl/schema/KeyValueSchemaTest.java | 10 +-
.../client/impl/schema/PrimitiveSchemaTest.java | 11 +-
.../client/impl/schema/SchemaBuilderTest.java | 3 +-
.../schema/SupportVersioningAvroSchemaTest.java | 2 +-
.../SupportVersioningKeyValueSchemaTest.java | 8 +-
.../impl/schema/generic/GenericAvroReaderTest.java | 4 +
.../generic/GenericProtobufNativeReaderTest.java | 2 +-
.../apache/pulsar/common/schema/KeyValueTest.java | 2 +-
.../pulsar/common/policies/data/OldPolicies.java | 5 +
.../pulsar/common/protocol/ByteBufPairTest.java | 1 +
.../semaphore/AsyncDualMemoryLimiterUtilTest.java | 12 +-
.../common/semaphore/AsyncSemaphoreImplTest.java | 2 +-
.../ConcurrentBitSetRecyclableTest.java | 2 +
.../pulsar/functions/instance/ContextImplTest.java | 7 +-
.../instance/JavaInstanceRunnableTest.java | 10 +-
.../instance/ProducerBuilderFactoryTest.java | 4 +-
.../functions/instance/ProducerCacheTest.java | 8 +-
.../pulsar/functions/instance/SinkRecordTest.java | 3 +-
.../instance/state/BKStateStoreImplTest.java | 1 +
.../pulsar/functions/sink/PulsarSinkTest.java | 58 ++---
.../functions/source/PulsarFunctionRecordTest.java | 5 +-
.../source/batch/BatchSourceExecutorTest.java | 24 +--
.../windowing/WindowFunctionExecutorTest.java | 4 +
.../functions/windowing/WindowManagerTest.java | 93 ++++----
.../KubernetesSecretsTokenAuthProviderTest.java | 6 +
.../pulsar/functions/runtime/RuntimeUtilsTest.java | 1 +
.../runtime/kubernetes/KubernetesRuntimeTest.java | 2 +-
.../functions/utils/FunctionConfigUtilsTest.java | 5 +
.../functions/utils/SinkConfigUtilsTest.java | 3 +
.../worker/FunctionMetaDataManagerTest.java | 3 +
.../worker/FunctionRuntimeManagerTest.java | 2 +
.../worker/FunctionWorkerStarterTest.java | 2 +-
.../pulsar/functions/worker/LeaderServiceTest.java | 7 +-
.../functions/worker/SchedulerManagerTest.java | 1 +
.../pulsar/functions/worker/WorkerUtilsTest.java | 1 +
.../worker/rest/api/FunctionsImplTest.java | 1 +
.../rest/api/v2/FunctionApiV2ResourceTest.java | 1 +
.../rest/api/v3/AbstractFunctionsResourceTest.java | 5 +-
.../rest/api/v3/FunctionApiV3ResourceTest.java | 1 +
.../rest/api/v3/SourceApiV3ResourceTest.java | 1 +
.../AuditorCheckAllLedgersTaskTest.java | 1 +
.../replication/AuditorLedgerCheckerTest.java | 1 +
.../AuditorPlacementPolicyCheckTest.java | 7 +
.../replication/AuditorReplicasCheckTest.java | 1 +
.../replication/BookKeeperClusterTestCase.java | 2 +-
.../replication/BookieLedgerIndexTest.java | 2 +-
.../replication/TestReplicationWorker.java | 2 +
.../bookkeeper/replication/ZooKeeperUtil.java | 2 +-
.../metadata/BacklogQuotaCompatibilityTest.java | 1 +
.../pulsar/metadata/BaseMetadataStoreTest.java | 1 +
.../pulsar/metadata/DualMetadataCacheTest.java | 2 +-
.../apache/pulsar/metadata/MetadataCacheTest.java | 2 +-
.../org/apache/pulsar/metadata/TestZKServer.java | 3 +-
.../org/apache/pulsar/metadata/ZKSessionTest.java | 4 +-
.../LedgerUnderreplicationManagerTest.java | 1 +
.../bookkeeper/PulsarRegistrationClientTest.java | 1 +
.../metadata/impl/RocksdbMetadataStoreTest.java | 1 +
.../bookkeeper/BookKeeperPackagesStorageTest.java | 1 +
.../bookkeeper/bookkeeper/test/ZooKeeperUtil.java | 1 +
.../filesystem/FileSystemPackagesStorageTest.java | 1 +
.../impl/AutoCloseUselessClientConProxyTest.java | 1 +
.../proxy/server/ProxyAdditionalServletTest.java | 2 +
.../ProxyAuthenticatedProducerConsumerTest.java | 1 +
.../proxy/server/ProxyAuthenticationTest.java | 5 +
.../proxy/server/ProxyConfigurationTest.java | 1 +
.../proxy/server/ProxyKeyStoreTlsWithAuthTest.java | 1 +
.../server/ProxyKeyStoreTlsWithoutAuthTest.java | 1 +
.../pulsar/proxy/server/ProxyParserTest.java | 1 +
.../pulsar/proxy/server/ProxyRefreshAuthTest.java | 2 +
.../proxy/server/ProxyRolesEnforcementTest.java | 4 +
.../proxy/server/ProxyServiceStarterTest.java | 2 +
.../org/apache/pulsar/proxy/server/ProxyTest.java | 2 +
.../proxy/server/ProxyWithAuthorizationTest.java | 2 +
.../server/ProxyWithJwtAuthorizationTest.java | 6 +
.../server/ProxyWithoutServiceDiscoveryTest.java | 2 +
.../Oauth2PerformanceTransactionTest.java | 1 +
.../pulsar/testclient/PerfClientUtilsTest.java | 1 +
.../testclient/PerformanceTransactionTest.java | 1 +
.../coordinator/impl/TxnLogBufferedWriterTest.java | 16 +-
.../WebSocketHttpServletRequestWrapperTest.java | 1 +
.../websocket/admin/WebSocketWebResourceTest.java | 1 +
.../offload/jcloud/impl/DataBlockHeaderTest.java | 2 +-
.../offload/jcloud/impl/MockManagedLedger.java | 1 +
336 files changed, 1483 insertions(+), 409 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/OpenTelemetryCustomLabelsTest.java
