This is an automated email from the ASF dual-hosted git repository.
aahmed pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 94bf13f [Documentation] Fix ThresholdShedder Typo (#9933)
add c4aaf41 Add TestNG groups to pulsar-broker (#9712)
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci-unit-broker-other.yaml | 4 +-
build/{retry.sh => retry_integration.sh} | 5 +
build/run_integration_group.sh | 8 +-
build/run_unit_group.sh | 86 ++-----
.../apache/pulsar/tests/PulsarTestListener.java | 4 +-
.../org/apache/pulsar/tests/ThreadDumpUtil.java | 2 +-
.../pulsar/broker/web/PulsarWebResource.java | 14 +-
.../org/apache/pulsar/PulsarBrokerStarterTest.java | 6 +-
.../broker/BookKeeperClientFactoryImplTest.java | 1 +
.../apache/pulsar/broker/SLAMonitoringTest.java | 24 +-
.../broker/admin/AdminApiDelayedDelivery.java | 2 +-
.../broker/admin/AdminApiGetLastMessageIdTest.java | 1 +
.../broker/admin/AdminApiMaxUnackedMessages.java | 1 +
.../pulsar/broker/admin/AdminApiOffloadTest.java | 3 +-
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 1 +
.../pulsar/broker/admin/AdminApiSchemaTest.java | 4 +-
.../admin/AdminApiSchemaValidationEnforced.java | 1 +
.../apache/pulsar/broker/admin/AdminApiTest.java | 24 +-
.../apache/pulsar/broker/admin/AdminApiTest2.java | 1 +
.../pulsar/broker/admin/AdminApiTlsAuthTest.java | 1 +
.../pulsar/broker/admin/AdminResourceTest.java | 1 +
.../org/apache/pulsar/broker/admin/AdminTest.java | 3 +-
.../pulsar/broker/admin/AdminTopicApiTest.java | 2 +-
.../apache/pulsar/broker/admin/BookiesApiTest.java | 10 +-
.../broker/admin/BrokerAdminClientTlsAuthTest.java | 1 +
.../broker/admin/CreateSubscriptionTest.java | 1 +
.../broker/admin/IncrementPartitionsTest.java | 1 +
.../broker/admin/MaxUnackedMessagesTest.java | 1 +
.../apache/pulsar/broker/admin/NamespacesTest.java | 8 +-
.../pulsar/broker/admin/PersistentTopicsTest.java | 1 +
.../pulsar/broker/admin/TopicAutoCreationTest.java | 1 +
.../pulsar/broker/admin/TopicMessageTTLTest.java | 1 +
.../broker/admin/TopicPoliciesDisableTest.java | 1 +
.../pulsar/broker/admin/TopicPoliciesTest.java | 2 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 46 ++--
.../pulsar/broker/admin/v1/V1_AdminApiTest2.java | 2 +-
.../pulsar/broker/admin/v3/PackagesApiTest.java | 1 +
.../apache/pulsar/broker/auth/AuthLogsTest.java | 1 +
.../pulsar/broker/auth/AuthorizationTest.java | 1 +
.../broker/cache/ResourceQuotaCacheTest.java | 1 +
.../delayed/InMemoryDeliveryTrackerTest.java | 3 +-
.../broker/intercept/BrokerInterceptorTest.java | 3 +-
.../intercept/BrokerInterceptorUtilsTest.java | 1 +
.../BrokerInterceptorWithClassLoaderTest.java | 2 +-
.../broker/intercept/CounterBrokerInterceptor.java | 9 +-
.../broker/intercept/InterceptFilterOutTest.java | 5 +-
.../intercept/MangedLedgerInterceptorImplTest.java | 14 +-
.../AntiAffinityNamespaceGroupTest.java | 1 +
.../loadbalance/BrokerVersionFilterTest.java | 4 +-
.../loadbalance/LeaderElectionServiceTest.java | 6 +-
.../broker/loadbalance/LoadBalancerTest.java | 19 +-
...kLimit.java => LoadReportNetworkLimitTest.java} | 3 +-
.../loadbalance/ModularLoadManagerImplTest.java | 1 +
.../ModularLoadManagerStrategyTest.java | 3 +-
.../loadbalance/SimpleLoadManagerImplTest.java | 5 +-
.../loadbalance/impl/LoadManagerSharedTest.java | 3 +-
.../loadbalance/impl/OverloadShedderTest.java | 1 +
.../broker/lookup/http/HttpTopicLookupv2Test.java | 5 +-
.../namespace/NamespaceCreateBundlesTest.java | 1 +
.../namespace/NamespaceOwnershipListenerTests.java | 1 +
.../broker/namespace/NamespaceServiceTest.java | 13 +-
.../broker/namespace/NamespaceUnloadingTest.java | 1 +
.../OwnerShipCacheForCurrentServerTest.java | 1 +
.../broker/namespace/OwnershipCacheTest.java | 5 +-
.../broker/protocol/ProtocolHandlerUtilsTest.java | 1 +
.../ProtocolHandlerWithClassLoaderTest.java | 1 +
.../broker/protocol/ProtocolHandlersTest.java | 1 +
.../broker/service/AdvertisedAddressTest.java | 1 +
.../broker/service/BacklogQuotaManagerTest.java | 7 +-
.../pulsar/broker/service/BatchMessageTest.java | 25 +-
.../pulsar/broker/service/BkEnsemblesTestBase.java | 6 +-
.../broker/service/BrokerBkEnsemblesTests.java | 5 +-
.../broker/service/BrokerBookieIsolationTest.java | 5 +-
.../broker/service/BrokerEntryMetadataE2ETest.java | 1 +
.../BrokerServiceAutoSubscriptionCreationTest.java | 3 +-
.../BrokerServiceAutoTopicCreationTest.java | 4 +-
.../pulsar/broker/service/BrokerServiceTest.java | 3 +-
.../service/BrokerServiceThrottlingTest.java | 14 +-
.../pulsar/broker/service/BrokerTestBase.java | 2 -
...istentHashingStickyKeyConsumerSelectorTest.java | 21 +-
.../broker/service/ConsumedLedgersTrimTest.java | 4 +-
.../service/CurrentLedgerRolloverIfFullTest.java | 4 +-
.../broker/service/DistributedIdGeneratorTest.java | 3 +-
.../broker/service/EnableProxyProtocolTest.java | 1 +
.../broker/service/ExclusiveProducerTest.java | 3 +-
...angeAutoSplitStickyKeyConsumerSelectorTest.java | 5 +-
...angeExclusiveStickyKeyConsumerSelectorTest.java | 1 +
.../broker/service/InactiveTopicDeleteTest.java | 2 +-
.../pulsar/broker/service/MaxMessageSizeTest.java | 1 +
...zation.java => MessageIdSerializationTest.java} | 3 +-
.../service/MessagePublishBufferThrottleTest.java | 3 +-
.../pulsar/broker/service/MessageTTLTest.java | 8 +-
.../broker/service/NonPersistentTopicE2ETest.java | 11 +-
.../pulsar/broker/service/NullValueTest.java | 1 +
.../broker/service/OpportunisticStripingTest.java | 3 +-
.../pulsar/broker/service/PartitionKeyTest.java | 4 +-
.../pulsar/broker/service/PeerReplicatorTest.java | 3 +-
.../PersistentDispatcherFailoverConsumerTest.java | 1 +
.../broker/service/PersistentFailoverE2ETest.java | 16 +-
.../service/PersistentMessageFinderTest.java | 23 +-
.../broker/service/PersistentQueueE2ETest.java | 5 +-
.../service/PersistentTopicConcurrentTest.java | 17 +-
.../broker/service/PersistentTopicE2ETest.java | 12 +-
.../pulsar/broker/service/PersistentTopicTest.java | 44 ++--
.../PrecisTopicPublishRateThrottleTest.java | 1 +
.../broker/service/PublishRateLimiterTest.java | 6 +-
.../pulsar/broker/service/RackAwareTest.java | 1 +
.../broker/service/ReplicatorGlobalNSTest.java | 1 +
.../broker/service/ReplicatorRateLimiterTest.java | 1 +
.../pulsar/broker/service/ReplicatorTest.java | 14 +-
.../pulsar/broker/service/ReplicatorTestBase.java | 2 +-
.../pulsar/broker/service/ReplicatorTlsTest.java | 2 +-
.../pulsar/broker/service/ResendRequestTest.java | 7 +-
.../pulsar/broker/service/ServerCnxTest.java | 20 +-
.../broker/service/SubscriptionSeekTest.java | 10 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 1 +
.../pulsar/broker/service/TopicOwnerTest.java | 1 +
.../service/TopicPoliciesServiceDisableTest.java | 1 +
.../broker/service/TopicTerminationTest.java | 8 +-
.../service/TransactionMarkerDeleteTest.java | 1 +
.../TransactionMetadataStoreServiceTest.java | 1 +
.../broker/service/persistent/ChecksumTest.java | 4 +-
.../service/persistent/DelayedDeliveryTest.java | 4 +-
.../service/persistent/MessageDuplicationTest.java | 47 ++--
...herFailoverConsumerStreamingDispatcherTest.java | 6 +-
...rsistentFailoverStreamingDispatcherE2ETest.java | 2 +
...ntStickyKeyDispatcherMultipleConsumersTest.java | 2 +-
...istentStreamingDispatcherBlockConsumerTest.java | 3 +
...eDispatchStreamingDispatcherThrottlingTest.java | 3 +
.../persistent/PersistentSubscriptionTest.java | 1 +
.../PersistentTopicStreamingDispatcherE2ETest.java | 3 +
.../PersistentTopicStreamingDispatcherTest.java | 2 +
.../service/persistent/PersistentTopicTest.java | 4 +-
.../ReplicatedSubscriptionConfigTest.java | 3 +-
.../ReplicatedSubscriptionSnapshotCacheTest.java | 6 +-
...ReplicatedSubscriptionsSnapshotBuilderTest.java | 11 +-
...roducerConsumerTestStreamingDispatcherTest.java | 3 +
.../service/persistent/TopicDuplicationTest.java | 1 +
.../schema/AvroSchemaCompatibilityCheckTest.java | 3 +
.../schema/BookkeeperSchemaStorageTest.java | 1 +
.../broker/service/schema/ClientGetSchemaTest.java | 5 +-
.../schema/JsonSchemaCompatibilityCheckTest.java | 1 +
.../KeyValueSchemaCompatibilityCheckTest.java | 1 +
.../schema/PartitionedTopicsSchemaTest.java | 1 +
...ProtobufNativeSchemaCompatibilityCheckTest.java | 1 +
.../ProtobufSchemaCompatibilityCheckTest.java | 3 +
.../broker/service/schema/SchemaServiceTest.java | 1 +
.../schema/validator/SchemaDataValidatorTest.java | 1 +
...RegistryServiceWithSchemaDataValidatorTest.java | 1 +
.../StreamingEntryReaderTests.java | 36 ++-
.../broker/service/utils/ClientChannelHelper.java | 8 +-
.../stats/BookieClientsStatsGeneratorTest.java | 3 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 1 +
.../broker/stats/ManagedCursorMetricsTest.java | 14 +-
.../broker/stats/ManagedLedgerMetricsTest.java | 3 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 17 +-
.../pulsar/broker/stats/SubscriptionStatsTest.java | 1 +
.../prometheus/AggregatedNamespaceStatsTest.java | 3 +-
.../NamespaceEventsSystemTopicServiceTest.java | 1 +
.../broker/transaction/TransactionConsumeTest.java | 3 +-
.../broker/transaction/TransactionProduceTest.java | 1 +
.../buffer/InMemTransactionBufferReaderTest.java | 5 +-
.../buffer/TransactionBufferClientTest.java | 1 +
.../transaction/buffer/TransactionBufferTest.java | 9 +-
.../buffer/TransactionEntryImplTest.java | 1 +
.../buffer/TransactionLowWaterMarkTest.java | 7 +-
.../buffer/TransactionStablePositionTest.java | 5 +-
.../TransactionCoordinatorClientTest.java | 2 +-
.../TransactionMetaStoreAssignmentTest.java | 7 +-
.../pendingack/PendingAckInMemoryDeleteTest.java | 1 +
.../pulsar/broker/web/RestExceptionTest.java | 1 +
.../apache/pulsar/broker/web/WebServiceTest.java | 7 +-
.../broker/zookeeper/ClusterMetadataSetupTest.java | 1 +
.../zookeeper/ZooKeeperClientAspectJTest.java | 5 +-
.../ZooKeeperSessionExpireRecoveryTest.java | 3 +-
.../client/api/KeySharedSubscriptionTest.java | 2 +-
.../client/impl/ConsumerDedupPermitsUpdate.java | 124 ----------
.../KeyStoreTlsProducerConsumerTestWithAuth.java | 268 ---------------------
...KeyStoreTlsProducerConsumerTestWithoutAuth.java | 254 -------------------
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 5 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 22 +-
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 19 +-
.../pulsar/schema/PartitionedTopicSchemaTest.java | 1 +
.../java/org/apache/pulsar/schema/SchemaTest.java | 3 +
.../SchemaCompatibilityCheckTest.java | 2 +-
.../pulsar/utils/SimpleTextOutputStreamTest.java | 1 +
.../apache/pulsar/utils/StatsOutputStreamTest.java | 1 +
.../pulsar/zookeeper/LocalBookkeeperEnsemble.java | 12 +-
188 files changed, 584 insertions(+), 1145 deletions(-)
copy build/{retry.sh => retry_integration.sh} (91%)
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/{LoadReportNetworkLimit.java
=> LoadReportNetworkLimitTest.java} (96%)
rename
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/{MessageIdSerialization.java
=> MessageIdSerializationTest.java} (96%)
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConsumerDedupPermitsUpdate.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/KeyStoreTlsProducerConsumerTestWithAuth.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/KeyStoreTlsProducerConsumerTestWithoutAuth.java
