You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2020/11/12 14:44:40 UTC
[pulsar] branch master updated (48e98e4 -> c4da921)
This is an automated email from the ASF dual-hosted git repository.
zhaijia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 48e98e4 Remove CGO client from repo (#8514)
add c4da921 Reduce memory leaks in pulsar-broker tests (#8526)
No new revisions were added by this update.
Summary of changes:
.../pulsar/broker/service/BrokerService.java | 3 +-
.../apache/pulsar/broker/SLAMonitoringTest.java | 2 +-
.../broker/admin/AdminApiDelayedDelivery.java | 2 +-
.../broker/admin/AdminApiGetLastMessageIdTest.java | 2 +-
.../broker/admin/AdminApiMaxUnackedMessages.java | 2 +-
.../pulsar/broker/admin/AdminApiOffloadTest.java | 12 ++-
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 2 +-
.../pulsar/broker/admin/AdminApiSchemaTest.java | 2 +-
.../admin/AdminApiSchemaValidationEnforced.java | 2 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 3 +-
.../apache/pulsar/broker/admin/AdminApiTest2.java | 7 +-
.../pulsar/broker/admin/AdminApiTlsAuthTest.java | 2 +-
.../pulsar/broker/admin/AdminResourceTest.java | 2 +-
.../org/apache/pulsar/broker/admin/AdminTest.java | 2 +-
.../pulsar/broker/admin/AdminTopicApiTest.java | 2 +-
.../apache/pulsar/broker/admin/BookiesApiTest.java | 2 +-
.../broker/admin/BrokerAdminClientTlsAuthTest.java | 2 +-
.../broker/admin/CreateSubscriptionTest.java | 2 +-
.../broker/admin/IncrementPartitionsTest.java | 2 +-
.../broker/admin/MaxUnackedMessagesTest.java | 2 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 2 +-
.../pulsar/broker/admin/PersistentTopicsTest.java | 4 +-
.../pulsar/broker/admin/TopicAutoCreationTest.java | 2 +-
.../pulsar/broker/admin/TopicMessageTTLTest.java | 3 +-
.../broker/admin/TopicPoliciesDisableTest.java | 2 +-
.../pulsar/broker/admin/TopicPoliciesTest.java | 2 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 2 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest2.java | 8 +-
.../pulsar/broker/auth/AuthorizationTest.java | 2 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 88 +++++++++++-----------
.../broker/cache/ResourceQuotaCacheTest.java | 2 +-
.../broker/intercept/BrokerInterceptorTest.java | 2 +-
.../AntiAffinityNamespaceGroupTest.java | 2 +-
.../loadbalance/LeaderElectionServiceTest.java | 4 +-
.../broker/loadbalance/LoadBalancerTest.java | 25 +++---
.../broker/loadbalance/LoadReportNetworkLimit.java | 2 +-
.../loadbalance/ModularLoadManagerImplTest.java | 2 +-
.../loadbalance/SimpleLoadManagerImplTest.java | 2 +-
.../namespace/NamespaceCreateBundlesTest.java | 2 +-
.../namespace/NamespaceOwnershipListenerTests.java | 2 +-
.../broker/namespace/NamespaceServiceTest.java | 2 +-
.../broker/namespace/NamespaceUnloadingTest.java | 2 +-
.../OwnerShipCacheForCurrentServerTest.java | 2 +-
.../broker/namespace/OwnershipCacheTest.java | 2 +-
.../broker/protocol/ProtocolHandlersTest.java | 2 +-
.../broker/service/AdvertisedAddressTest.java | 2 +-
.../broker/service/BacklogQuotaManagerTest.java | 2 +-
.../pulsar/broker/service/BatchMessageTest.java | 2 +-
.../pulsar/broker/service/BkEnsemblesTestBase.java | 2 +-
.../broker/service/BrokerBookieIsolationTest.java | 2 +-
.../BrokerServiceAutoSubscriptionCreationTest.java | 4 +-
.../BrokerServiceAutoTopicCreationTest.java | 4 +-
.../pulsar/broker/service/BrokerServiceTest.java | 2 +-
.../service/BrokerServiceThrottlingTest.java | 2 +-
.../broker/service/DistributedIdGeneratorTest.java | 2 +-
.../pulsar/broker/service/MaxMessageSizeTest.java | 2 +-
.../broker/service/NonPersistentTopicE2ETest.java | 2 +-
.../pulsar/broker/service/NullValueTest.java | 2 +-
.../pulsar/broker/service/PartitionKeyTest.java | 2 +-
.../pulsar/broker/service/PeerReplicatorTest.java | 2 +-
.../PersistentDispatcherFailoverConsumerTest.java | 23 +++++-
.../broker/service/PersistentFailoverE2ETest.java | 4 +-
.../broker/service/PersistentQueueE2ETest.java | 2 +-
.../broker/service/PersistentTopicE2ETest.java | 3 +-
.../pulsar/broker/service/PersistentTopicTest.java | 4 +-
.../pulsar/broker/service/RackAwareTest.java | 2 +-
.../broker/service/ReplicatorGlobalNSTest.java | 2 +-
.../broker/service/ReplicatorRateLimiterTest.java | 2 +-
.../pulsar/broker/service/ReplicatorTest.java | 4 +-
.../pulsar/broker/service/ReplicatorTestBase.java | 12 ++-
.../pulsar/broker/service/ReplicatorTlsTest.java | 2 +-
.../pulsar/broker/service/ResendRequestTest.java | 2 +-
.../pulsar/broker/service/ServerCnxTest.java | 2 +-
.../broker/service/SubscriptionSeekTest.java | 2 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 2 +-
.../pulsar/broker/service/TopicOwnerTest.java | 2 +-
.../service/TopicPoliciesServiceDisableTest.java | 2 +-
.../broker/service/TopicTerminationTest.java | 2 +-
.../service/TransactionMarkerDeleteTest.java | 2 +-
.../TransactionMetadataStoreServiceTest.java | 2 +-
.../broker/service/persistent/ChecksumTest.java | 2 +-
.../service/persistent/DelayedDeliveryTest.java | 2 +-
.../persistent/PersistentSubscriptionTest.java | 2 +-
.../ReplicatedSubscriptionConfigTest.java | 2 +-
.../service/persistent/TopicDuplicationTest.java | 2 +-
.../broker/service/schema/ClientGetSchemaTest.java | 2 +-
.../broker/service/schema/SchemaServiceTest.java | 2 +-
.../stats/BookieClientsStatsGeneratorTest.java | 2 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 2 +-
.../broker/stats/ManagedLedgerMetricsTest.java | 2 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 2 +-
.../NamespaceEventsSystemTopicServiceTest.java | 2 +-
.../broker/transaction/TransactionConsumeTest.java | 2 +-
.../broker/transaction/TransactionProduceTest.java | 2 +-
.../buffer/TransactionBufferClientTest.java | 13 +++-
.../transaction/buffer/TransactionBufferTest.java | 2 +-
.../coordinator/TransactionMetaStoreTestBase.java | 18 +++++
.../apache/pulsar/broker/web/WebServiceTest.java | 14 +++-
.../broker/zookeeper/ClusterMetadataSetupTest.java | 2 +-
.../zookeeper/ZooKeeperClientAspectJTest.java | 2 +-
.../ZooKeeperSessionExpireRecoveryTest.java | 2 +-
.../api/AuthenticatedProducerConsumerTest.java | 2 +-
.../AuthenticationTlsHostnameVerificationTest.java | 2 +-
.../api/AuthorizationProducerConsumerTest.java | 2 +-
.../pulsar/client/api/BrokerServiceLookupTest.java | 2 +-
.../org/apache/pulsar/client/api/BytesKeyTest.java | 2 +-
.../client/api/ClientDeduplicationFailureTest.java | 2 +-
.../pulsar/client/api/ClientDeduplicationTest.java | 2 +-
.../apache/pulsar/client/api/ClientErrorsTest.java | 2 +-
.../pulsar/client/api/ConsumerAckListTest.java | 2 +-
.../client/api/ConsumerBatchReceiveTest.java | 7 +-
.../pulsar/client/api/ConsumerCleanupTest.java | 2 +-
.../pulsar/client/api/ConsumerRedeliveryTest.java | 2 +-
.../pulsar/client/api/DeadLetterTopicTest.java | 2 +-
.../client/api/DispatcherBlockConsumerTest.java | 2 +-
.../api/ExposeMessageRedeliveryCountTest.java | 2 +-
.../apache/pulsar/client/api/InterceptorsTest.java | 2 +-
.../client/api/KeySharedSubscriptionTest.java | 2 +-
.../client/api/MessageDispatchThrottlingTest.java | 2 +-
.../client/api/MutualAuthenticationTest.java | 2 +-
.../client/api/NonDurableSubscriptionTest.java | 2 +-
.../pulsar/client/api/NonPersistentTopicTest.java | 3 +-
.../pulsar/client/api/PartitionCreationTest.java | 2 +-
.../api/PartitionedProducerConsumerTest.java | 2 +-
.../pulsar/client/api/ProducerCleanupTest.java | 2 +-
.../pulsar/client/api/ProducerCreationTest.java | 2 +-
...MultiListenersWithInternalListenerNameTest.java | 2 +-
...tiListenersWithoutInternalListenerNameTest.java | 2 +-
.../apache/pulsar/client/api/RetryTopicTest.java | 2 +-
.../pulsar/client/api/ServiceUrlProviderTest.java | 2 +-
.../client/api/SimpleProducerConsumerStatTest.java | 2 +-
.../client/api/SimpleProducerConsumerTest.java | 5 +-
.../apache/pulsar/client/api/SimpleSchemaTest.java | 2 +-
.../api/SimpleTypedProducerConsumerTest.java | 2 +-
.../org/apache/pulsar/client/api/TenantTest.java | 2 +-
.../pulsar/client/api/TlsProducerConsumerBase.java | 2 +-
.../TokenAuthenticatedProducerConsumerTest.java | 2 +-
...kenOauth2AuthenticatedProducerConsumerTest.java | 2 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 2 +-
.../client/api/v1/V1_ProducerConsumerTest.java | 2 +-
.../client/impl/AdminApiKeyStoreTlsAuthTest.java | 2 +-
.../impl/BatchMessageIndexAckDisableTest.java | 2 +-
.../client/impl/BatchMessageIndexAckTest.java | 2 +-
.../client/impl/BrokerClientIntegrationTest.java | 8 +-
.../client/impl/CompactedOutBatchMessageTest.java | 2 +-
.../pulsar/client/impl/ConnectionPoolTest.java | 2 +-
.../client/impl/ConsumeBaseExceptionTest.java | 2 +-
.../client/impl/ConsumerAckResponseTest.java | 2 +-
.../client/impl/ConsumerConfigurationTest.java | 2 +-
.../client/impl/ConsumerDedupPermitsUpdate.java | 2 +-
.../client/impl/ConsumerUnsubscribeTest.java | 2 +-
.../KeyStoreTlsProducerConsumerTestWithAuth.java | 2 +-
...KeyStoreTlsProducerConsumerTestWithoutAuth.java | 2 +-
.../pulsar/client/impl/MessageChunkingTest.java | 2 +-
.../apache/pulsar/client/impl/MessageIdTest.java | 2 +-
.../pulsar/client/impl/MessageParserTest.java | 2 +-
.../client/impl/MessagePublishThrottlingTest.java | 3 +-
.../pulsar/client/impl/MessageRedeliveryTest.java | 2 +-
.../pulsar/client/impl/NegativeAcksTest.java | 2 +-
.../client/impl/PatternTopicsConsumerImplTest.java | 2 +-
.../PerMessageUnAcknowledgedRedeliveryTest.java | 2 +-
.../pulsar/client/impl/ProducerSemaphoreTest.java | 2 +-
.../client/impl/PulsarMultiHostClientTest.java | 2 +-
.../apache/pulsar/client/impl/RawReaderTest.java | 2 +-
.../org/apache/pulsar/client/impl/ReaderTest.java | 2 +-
.../pulsar/client/impl/SchemaDeleteTest.java | 2 +-
.../pulsar/client/impl/TopicDoesNotExistsTest.java | 2 +-
.../pulsar/client/impl/TopicFromMessageTest.java | 2 +-
.../impl/TopicPublishThrottlingInitTest.java | 2 +-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 2 +-
.../client/impl/TransactionEndToEndTest.java | 2 +-
.../impl/UnAcknowledgedMessagesTimeoutTest.java | 2 +-
.../pulsar/client/impl/ZeroQueueSizeTest.java | 2 +-
.../pulsar/compaction/CompactedTopicTest.java | 2 +-
.../apache/pulsar/compaction/CompactionTest.java | 2 +-
.../apache/pulsar/compaction/CompactorTest.java | 2 +-
.../service/web/DiscoveryServiceWebTest.java | 2 +-
.../worker/PulsarFunctionE2ESecurityTest.java | 2 +-
.../worker/PulsarFunctionLocalRunTest.java | 2 +-
.../worker/PulsarFunctionPublishTest.java | 2 +-
.../worker/PulsarWorkerAssignmentTest.java | 2 +-
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 2 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 2 +-
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 2 +-
.../pulsar/schema/PartitionedTopicSchemaTest.java | 2 +-
.../java/org/apache/pulsar/schema/SchemaTest.java | 2 +-
.../SchemaCompatibilityCheckTest.java | 2 +-
.../stats/client/PulsarBrokerStatsClientTest.java | 2 +-
.../websocket/proxy/ProxyAuthenticationTest.java | 2 +-
.../websocket/proxy/ProxyAuthorizationTest.java | 2 +-
.../websocket/proxy/ProxyConfigurationTest.java | 2 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 2 +-
.../proxy/ProxyPublishConsumeTlsTest.java | 2 +-
.../proxy/ProxyPublishConsumeWithoutZKTest.java | 2 +-
.../proxy/v1/V1_ProxyAuthenticationTest.java | 2 +-
195 files changed, 348 insertions(+), 276 deletions(-)