This is an automated email from the ASF dual-hosted git repository.
aahmed pushed a change to branch github_exp3
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
discard acdd473 Add retry and timeout annotation extension
discard 87d4273 Update
omit be934e0 Add basic test retry handler
omit 93ccd05 Add Timeout to tests
add ba1d81d Add Timeout to tests
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (acdd473)
\
N -- N -- N refs/heads/github_exp3 (ba1d81d)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/PulsarBrokerStarterTest.java | 18 ++---
.../apache/pulsar/broker/SLAMonitoringTest.java | 12 ++--
.../broker/admin/AdminApiGetLastMessageIdTest.java | 8 +--
.../pulsar/broker/admin/AdminApiOffloadTest.java | 8 +--
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 20 +++---
.../pulsar/broker/admin/AdminApiSchemaTest.java | 10 +--
.../admin/AdminApiSchemaValidationEnforced.java | 14 ++--
.../apache/pulsar/broker/admin/AdminApiTest.java | 74 ++++++++++----------
.../apache/pulsar/broker/admin/AdminApiTest2.java | 42 ++++++------
.../pulsar/broker/admin/AdminApiTlsAuthTest.java | 30 ++++----
.../pulsar/broker/admin/AdminResourceTest.java | 4 +-
.../org/apache/pulsar/broker/admin/AdminTest.java | 22 +++---
.../broker/admin/BrokerAdminClientTlsAuthTest.java | 8 +--
.../broker/admin/CreateSubscriptionTest.java | 10 +--
.../broker/admin/IncrementPartitionsTest.java | 8 +--
.../apache/pulsar/broker/admin/NamespacesTest.java | 54 +++++++--------
.../pulsar/broker/admin/PersistentTopicsTest.java | 18 ++---
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 76 ++++++++++----------
.../pulsar/broker/admin/v1/V1_AdminApiTest2.java | 32 ++++-----
.../broker/auth/AuthenticationServiceTest.java | 4 +-
.../pulsar/broker/auth/AuthorizationTest.java | 8 +--
.../broker/cache/ResourceQuotaCacheTest.java | 8 +--
.../delayed/InMemoryDeliveryTrackerTest.java | 4 +-
.../AntiAffinityNamespaceGroupTest.java | 20 +++---
.../loadbalance/BrokerVersionFilterTest.java | 2 +-
.../broker/loadbalance/LoadBalancerTest.java | 28 ++++----
.../broker/loadbalance/LoadReportNetworkLimit.java | 6 +-
.../loadbalance/ModularLoadManagerImplTest.java | 20 +++---
.../ModularLoadManagerStrategyTest.java | 2 +-
.../loadbalance/SimpleLoadManagerImplTest.java | 26 +++----
.../loadbalance/impl/OverloadShedderTest.java | 12 ++--
.../broker/lookup/http/HttpTopicLookupv2Test.java | 10 +--
.../namespace/NamespaceCreateBundlesTest.java | 6 +-
.../broker/namespace/NamespaceServiceTest.java | 20 +++---
.../broker/namespace/NamespaceUnloadingTest.java | 8 +--
.../broker/namespace/OwnershipCacheTest.java | 18 ++---
.../broker/service/AdvertisedAddressTest.java | 6 +-
.../broker/service/BacklogQuotaManagerTest.java | 22 +++---
.../pulsar/broker/service/BatchMessageTest.java | 30 ++++----
.../broker/service/BrokerBkEnsemblesTests.java | 10 +--
.../broker/service/BrokerBookieIsolationTest.java | 10 +--
.../pulsar/broker/service/BrokerServiceTest.java | 32 ++++-----
.../service/BrokerServiceThrottlingTest.java | 12 ++--
.../broker/service/DistributedIdGeneratorTest.java | 12 ++--
.../HashRangeStickyKeyConsumerSelectorTest.java | 8 +--
.../pulsar/broker/service/MaxMessageSizeTest.java | 6 +-
.../broker/service/MessageIdSerialization.java | 10 +--
.../broker/service/NonPersistentTopicE2ETest.java | 8 +--
.../pulsar/broker/service/PartitionKeyTest.java | 10 +--
.../pulsar/broker/service/PeerReplicatorTest.java | 10 +--
.../PersistentDispatcherFailoverConsumerTest.java | 18 ++---
.../broker/service/PersistentFailoverE2ETest.java | 10 +--
.../service/PersistentMessageFinderTest.java | 4 +-
.../broker/service/PersistentQueueE2ETest.java | 14 ++--
.../service/PersistentTopicConcurrentTest.java | 10 +--
.../broker/service/PersistentTopicE2ETest.java | 72 +++++++++----------
.../pulsar/broker/service/PersistentTopicTest.java | 62 ++++++++---------
.../pulsar/broker/service/RackAwareTest.java | 12 ++--
.../broker/service/ReplicatorGlobalNSTest.java | 10 +--
.../broker/service/ReplicatorRateLimiterTest.java | 4 +-
.../pulsar/broker/service/ReplicatorTest.java | 16 ++---
.../pulsar/broker/service/ReplicatorTlsTest.java | 8 +--
.../pulsar/broker/service/ResendRequestTest.java | 4 +-
.../pulsar/broker/service/ServerCnxTest.java | 8 +--
.../broker/service/SubscriptionSeekTest.java | 14 ++--
.../broker/service/TopicTerminationTest.java | 28 ++++----
.../broker/service/persistent/ChecksumTest.java | 10 +--
.../service/persistent/DelayedDeliveryTest.java | 10 +--
.../persistent/PersistentSubscriptionTest.java | 8 +--
.../ReplicatedSubscriptionConfigTest.java | 10 +--
.../ReplicatedSubscriptionSnapshotCacheTest.java | 4 +-
...ReplicatedSubscriptionsSnapshotBuilderTest.java | 8 +--
.../schema/BaseAvroSchemaCompatibilityTest.java | 12 ++--
.../schema/BookkeeperSchemaStorageTest.java | 4 +-
.../broker/service/schema/ClientGetSchemaTest.java | 6 +-
.../schema/JsonSchemaCompatibilityCheckTest.java | 2 +-
.../KeyValueSchemaCompatibilityCheckTest.java | 62 ++++++++---------
.../schema/PartitionedTopicsSchemaTest.java | 6 +-
.../broker/service/schema/SchemaServiceTest.java | 32 ++++-----
.../schema/validator/SchemaDataValidatorTest.java | 12 ++--
...RegistryServiceWithSchemaDataValidatorTest.java | 16 ++---
.../stats/BookieClientsStatsGeneratorTest.java | 8 +--
.../broker/stats/ManagedLedgerMetricsTest.java | 6 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 8 +--
.../prometheus/AggregatedNamespaceStatsTest.java | 2 +-
.../buffer/InMemTransactionBufferReaderTest.java | 6 +-
.../buffer/PersistentTransactionBufferTest.java | 34 ++++-----
.../transaction/buffer/TransactionBufferTest.java | 22 +++---
.../buffer/TransactionEntryImplTest.java | 2 +-
.../pulsar/broker/web/RestExceptionTest.java | 6 +-
.../apache/pulsar/broker/web/WebServiceTest.java | 20 +++---
.../zookeeper/ZooKeeperClientAspectJTest.java | 8 +--
.../ZooKeeperSessionExpireRecoveryTest.java | 6 +-
.../api/AuthenticatedProducerConsumerTest.java | 16 ++---
.../AuthenticationTlsHostnameVerificationTest.java | 10 +--
.../api/AuthorizationProducerConsumerTest.java | 12 ++--
.../pulsar/client/api/BrokerServiceLookupTest.java | 34 ++++-----
.../org/apache/pulsar/client/api/BytesKeyTest.java | 8 +--
.../pulsar/client/api/ClientDeduplicationTest.java | 8 +--
.../apache/pulsar/client/api/ClientErrorsTest.java | 54 +++++++--------
.../pulsar/client/api/ConsumerRedeliveryTest.java | 8 +--
.../pulsar/client/api/DeadLetterTopicTest.java | 10 +--
.../client/api/DispatcherBlockConsumerTest.java | 20 +++---
.../api/ExposeMessageRedeliveryCountTest.java | 4 +-
.../apache/pulsar/client/api/InterceptorsTest.java | 24 +++----
.../client/api/KeySharedSubscriptionTest.java | 14 ++--
.../client/api/MessageDispatchThrottlingTest.java | 16 ++---
.../client/api/MutualAuthenticationTest.java | 6 +-
.../NonPersistentKeySharedSubscriptionTest.java | 14 ++--
.../pulsar/client/api/NonPersistentTopicTest.java | 28 ++++----
.../api/PartitionedProducerConsumerTest.java | 34 ++++-----
.../pulsar/client/api/ProducerConsumerBase.java | 2 +-
.../pulsar/client/api/ServiceUrlProviderTest.java | 8 +--
.../client/api/SimpleProducerConsumerStatTest.java | 16 ++---
.../client/api/SimpleProducerConsumerTest.java | 80 +++++++++++-----------
.../apache/pulsar/client/api/SimpleSchemaTest.java | 32 ++++-----
.../api/SimpleTypedProducerConsumerTest.java | 26 +++----
.../SubscriptionMessageDispatchThrottlingTest.java | 4 +-
.../pulsar/client/api/TlsHostVerification.java | 6 +-
.../pulsar/client/api/TlsProducerConsumerBase.java | 4 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 36 +++++-----
.../client/api/v1/V1_ProducerConsumerBase.java | 2 +-
.../client/api/v1/V1_ProducerConsumerTest.java | 58 ++++++++--------
.../impl/BatchMessageIdImplSerializationTest.java | 10 +--
.../client/impl/BrokerClientIntegrationTest.java | 18 ++---
.../client/impl/CompactedOutBatchMessageTest.java | 6 +-
.../pulsar/client/impl/ConnectionPoolTest.java | 8 +--
.../client/impl/ConsumeBaseExceptionTest.java | 8 +--
.../client/impl/ConsumerConfigurationTest.java | 12 ++--
.../client/impl/ConsumerDedupPermitsUpdate.java | 6 +-
.../client/impl/ConsumerUnsubscribeTest.java | 6 +-
.../apache/pulsar/client/impl/MessageIdTest.java | 18 ++---
.../pulsar/client/impl/MessageParserTest.java | 8 +--
.../pulsar/client/impl/MessageRedeliveryTest.java | 4 +-
.../pulsar/client/impl/NegativeAcksTest.java | 6 +-
.../client/impl/PatternTopicsConsumerImplTest.java | 4 +-
.../PerMessageUnAcknowledgedRedeliveryTest.java | 4 +-
.../pulsar/client/impl/RawMessageSerDeserTest.java | 2 +-
.../apache/pulsar/client/impl/RawReaderTest.java | 20 +++---
.../org/apache/pulsar/client/impl/ReaderTest.java | 10 +--
.../pulsar/client/impl/SchemaDeleteTest.java | 6 +-
.../client/impl/SequenceIdWithErrorTest.java | 6 +-
.../pulsar/client/impl/TopicFromMessageTest.java | 4 +-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 6 +-
.../impl/UnAcknowledgedMessagesTimeoutTest.java | 8 +--
.../pulsar/client/impl/ZeroQueueSizeTest.java | 22 +++---
.../pulsar/common/naming/NamespaceBundleTest.java | 12 ++--
.../pulsar/common/naming/NamespaceBundlesTest.java | 8 +--
.../common/naming/ServiceConfigurationTest.java | 8 +--
.../pulsar/compaction/CompactedTopicTest.java | 8 +--
.../apache/pulsar/compaction/CompactionTest.java | 58 ++++++++--------
.../apache/pulsar/compaction/CompactorTest.java | 12 ++--
.../service/web/DiscoveryServiceWebTest.java | 6 +-
.../worker/PulsarFunctionE2ESecurityTest.java | 8 +--
.../worker/PulsarFunctionLocalRunTest.java | 16 ++---
.../worker/PulsarFunctionPublishTest.java | 6 +-
.../functions/worker/PulsarFunctionStateTest.java | 6 +-
.../worker/PulsarWorkerAssignmentTest.java | 8 +--
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 4 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 20 +++---
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 6 +-
.../stats/client/PulsarBrokerStatsClientTest.java | 8 +--
.../pulsar/utils/SimpleTextOutputStreamTest.java | 10 +--
.../apache/pulsar/utils/StatsOutputStreamTest.java | 14 ++--
.../websocket/proxy/ProxyAuthenticationTest.java | 12 ++--
.../websocket/proxy/ProxyAuthorizationTest.java | 6 +-
.../websocket/proxy/ProxyConfigurationTest.java | 4 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 20 +++---
.../proxy/ProxyPublishConsumeTlsTest.java | 4 +-
.../proxy/ProxyPublishConsumeWithoutZKTest.java | 4 +-
.../proxy/v1/V1_ProxyAuthenticationTest.java | 12 ++--
.../kafka/clients/consumer/ConsumerConnector.java | 4 +-
172 files changed, 1280 insertions(+), 1280 deletions(-)
