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