[pulsar] branch master updated (978efaf -> 991c2a2)

[mm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 978efaf  [proxy] Fix proxy to be able to re-send request body (#5361)
     add 991c2a2  Multiple unit tests improvements (#5439)

No new revisions were added by this update.

Summary of changes:
 .../apache/pulsar/tests/PulsarTestListener.java    |  17 +-
 .../mledger/impl/ManagedLedgerFactoryImpl.java     |  20 +-
 .../mledger/impl/ManagedLedgerBkTest.java          |   2 +
 .../bookkeeper/test/BookKeeperClusterTestCase.java |   1 +
 .../org/apache/bookkeeper/test/PortManager.java    |  97 ++---
 pom.xml                                            |   7 +-
 .../org/apache/pulsar/PulsarBrokerStarter.java     |  11 +-
 .../apache/pulsar/broker/NoOpShutdownService.java  |  19 +-
 .../org/apache/pulsar/broker/PulsarService.java    |  19 +-
 .../loadbalance/impl/SimpleLoadManagerImpl.java    |   2 +-
 .../pulsar/broker/service/BrokerService.java       |  10 +-
 .../stats/prometheus/NamespaceStatsAggregator.java |   1 +
 .../broker/BookKeeperClientFactoryImplTest.java    |   3 +
 .../apache/pulsar/broker/SLAMonitoringTest.java    |   4 +-
 .../apache/pulsar/broker/admin/AdminApiTest.java   |   6 +-
 .../apache/pulsar/broker/admin/AdminApiTest2.java  |   7 +-
 .../broker/admin/BrokerAdminClientTlsAuthTest.java |  14 +-
 .../pulsar/broker/admin/v1/V1_AdminApiTest.java    |   3 +
 .../pulsar/broker/admin/v1/V1_AdminApiTest2.java   |   4 +
 .../broker/auth/MockedPulsarServiceBaseTest.java   |  28 +-
 .../broker/cache/ResourceQuotaCacheTest.java       |  10 +-
 .../AntiAffinityNamespaceGroupTest.java            |  44 ++-
 .../broker/loadbalance/LoadBalancerTest.java       |   9 +-
 .../loadbalance/ModularLoadManagerImplTest.java    |  35 +-
 .../loadbalance/SimpleLoadManagerImplTest.java     |  13 +-
 .../namespace/NamespaceCreateBundlesTest.java      |   4 +-
 .../broker/namespace/NamespaceServiceTest.java     |   4 +-
 .../broker/namespace/OwnershipCacheTest.java       |   6 +-
 .../broker/service/AdvertisedAddressTest.java      |  22 +-
 .../broker/service/BacklogQuotaManagerTest.java    |   2 +
 .../pulsar/broker/service/BatchMessageTest.java    |  11 +-
 .../broker/service/BrokerBkEnsemblesTests.java     |   4 +-
 .../broker/service/BrokerBookieIsolationTest.java  |  26 +-
 .../pulsar/broker/service/MaxMessageSizeTest.java  |   2 +
 .../PersistentDispatcherFailoverConsumerTest.java  |  15 +-
 .../broker/service/PersistentFailoverE2ETest.java  |  30 +-
 .../service/PersistentMessageFinderTest.java       |  10 +-
 .../broker/service/PersistentQueueE2ETest.java     |   4 +-
 .../service/PersistentTopicConcurrentTest.java     |   2 +
 .../pulsar/broker/service/PersistentTopicTest.java |  12 +-
 .../pulsar/broker/service/ReplicatorTestBase.java  |   4 +
 .../pulsar/broker/service/ServerCnxTest.java       |  12 +-
 .../persistent/PersistentSubscriptionTest.java     |  14 +-
 .../pulsar/broker/stats/PrometheusMetricsTest.java |   3 -
 .../buffer/PersistentTransactionBufferTest.java    |  10 +-
 .../apache/pulsar/broker/web/WebServiceTest.java   |   6 +-
 .../api/AuthorizationProducerConsumerTest.java     |  27 +-
 .../pulsar/client/api/BrokerServiceLookupTest.java |  49 ++-
 .../client/api/ClientDeduplicationFailureTest.java |  19 +-
 .../client/api/DispatcherBlockConsumerTest.java    | 118 ++++---
 .../pulsar/client/api/NonPersistentTopicTest.java  |  10 +-
 .../pulsar/client/api/ServiceUrlProviderTest.java  |   2 +-
 .../pulsar/client/api/TlsProducerConsumerBase.java |   9 +
 .../client/api/v1/V1_ProducerConsumerTest.java     |   4 +-
 .../client/impl/BrokerClientIntegrationTest.java   |  56 ++-
 .../pulsar/client/impl/ConnectionPoolTest.java     |   6 +-
 .../pulsar/client/impl/TopicsConsumerImplTest.java |   1 +
 .../impl/UnAcknowledgedMessagesTimeoutTest.java    | 152 ++++----
 .../worker/PulsarFunctionE2ESecurityTest.java      |   6 +-
 .../worker/PulsarFunctionLocalRunTest.java         |   2 +
 .../worker/PulsarFunctionPublishTest.java          |   7 +-
 .../functions/worker/PulsarFunctionStateTest.java  | 389 ---------------------
 .../worker/PulsarWorkerAssignmentTest.java         |   2 +
 .../apache/pulsar/io/PulsarFunctionAdminTest.java  |   2 +
 .../apache/pulsar/io/PulsarFunctionE2ETest.java    |   6 +-
 .../websocket/proxy/ProxyPublishConsumeTest.java   |  13 +-
 .../pulsar/client/cli/PulsarClientToolTest.java    |  11 +-
 .../pulsar/client/impl/schema/BooleanSchema.java   |  15 +-
 .../pulsar/client/impl/schema/ByteBufSchema.java   |  15 +-
 .../client/impl/schema/ByteBufferSchema.java       |  19 +-
 .../pulsar/client/impl/schema/ByteSchema.java      |  15 +-
 .../pulsar/client/impl/schema/BytesSchema.java     |  16 +-
 .../pulsar/client/impl/schema/DateSchema.java      |  15 +-
 .../pulsar/client/impl/schema/DoubleSchema.java    |  16 +-
 .../pulsar/client/impl/schema/FloatSchema.java     |  15 +-
 .../pulsar/client/impl/schema/IntSchema.java       |  15 +-
 .../pulsar/client/impl/schema/LongSchema.java      |  15 +-
 .../pulsar/client/impl/schema/ShortSchema.java     |  15 +-
 .../pulsar/client/impl/schema/TimeSchema.java      |  15 +-
 .../pulsar/client/impl/schema/TimestampSchema.java |  15 +-
 .../apache/pulsar/common/util/RateLimiterTest.java |   3 +-
 .../ConcurrentSortedLongPairSetTest.java           |   4 +-
 .../service/web/DiscoveryServiceServlet.java       |   9 +
 .../service/web/ZookeeperCacheLoader.java          |   5 +-
 .../pulsar/functions/worker/WorkerService.java     |   8 +-
 .../pulsar/functions/worker/rest/WorkerServer.java |   1 +
 .../apache/pulsar/io/file/AbstractFileTests.java   |  52 ++-
 .../pulsar/io/file/FileConsumerThreadTests.java    |  48 +--
 .../pulsar/io/file/FileListingThreadTests.java     | 108 +++---
 .../pulsar/io/file/ProcessedFileThreadTests.java   | 104 +++---
 .../pulsar/io/flume/sink/StringSinkTests.java      |  29 +-
 .../pulsar/io/flume/source/StringSourceTests.java  |   6 +-
 pulsar-io/flume/src/test/resources/flume/sink.conf |   2 +-
 .../pulsar/zookeeper/LocalBookkeeperEnsemble.java  |   5 +-
 .../zookeeper/LocalZooKeeperConnectionService.java |   8 +-
 .../pulsar/zookeeper/ZooKeeperSessionWatcher.java  |  16 +-
 .../LocalZooKeeperConnectionServiceTest.java       |  17 +-
 .../MockedZooKeeperClientFactoryImpl.java          |  17 +-
 .../org/apache/pulsar/storm/PulsarBoltTest.java    |   4 +-
 .../org/apache/pulsar/storm/PulsarSpoutTest.java   |   4 +-
 100 files changed, 1072 insertions(+), 1059 deletions(-)
 copy pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMetadataImpl.java => pulsar-broker/src/main/java/org/apache/pulsar/broker/NoOpShutdownService.java (68%)
 delete mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/functions/worker/PulsarFunctionStateTest.java