[pulsar] branch master updated (b0f3ae0 -> 41814a7)

[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 b0f3ae0  fix doc (#10228)
     add 41814a7  Fix some ExecutorService leaks and use @Cleanup("shutdownNow") for cleanup (#10198)

No new revisions were added by this update.

Summary of changes:
 .../bookkeeper/mledger/impl/ManagedCursorTest.java |   5 +-
 .../bookkeeper/mledger/impl/ManagedLedgerTest.java |   7 +-
 .../bookkeeper/test/BookKeeperClusterTestCase.java |   2 +-
 .../bookkeeper/test/MockedBookKeeperTestCase.java  |   4 +-
 .../broker/MessagingServiceShutdownHook.java       |   2 +
 .../org/apache/pulsar/broker/PulsarService.java    |   5 +
 .../broker/MockedBookKeeperClientFactory.java      |   2 +-
 .../apache/pulsar/broker/SLAMonitoringTest.java    |   2 +-
 .../apache/pulsar/broker/admin/AdminApiTest.java   |   2 +-
 .../pulsar/broker/admin/v1/V1_AdminApiTest.java    |   2 +-
 .../broker/cache/ResourceQuotaCacheTest.java       |   2 +-
 .../AntiAffinityNamespaceGroupTest.java            |   2 +-
 .../broker/loadbalance/LoadBalancerTest.java       |   4 +-
 .../loadbalance/ModularLoadManagerImplTest.java    |   2 +-
 .../loadbalance/SimpleLoadManagerImplTest.java     |   2 +-
 .../broker/namespace/OwnershipCacheTest.java       |   2 +-
 .../pulsar/broker/service/BatchMessageTest.java    |   2 +-
 .../pulsar/broker/service/BrokerServiceTest.java   |   5 +-
 .../service/BrokerServiceThrottlingTest.java       |   6 +-
 .../broker/service/DistributedIdGeneratorTest.java |   4 +-
 .../broker/service/PersistentTopicE2ETest.java     |   7 +-
 .../pulsar/broker/service/PersistentTopicTest.java |   5 +-
 .../pulsar/broker/service/ReplicatorTest.java      |   3 +-
 .../pulsar/broker/service/ReplicatorTestBase.java  |   2 +-
 .../zookeeper/ZooKeeperClientAspectJTest.java      |   6 +-
 .../pulsar/client/api/DeadLetterTopicTest.java     |   3 +-
 .../client/api/DispatcherBlockConsumerTest.java    |   5 +-
 .../pulsar/client/api/NonPersistentTopicTest.java  |   7 +-
 .../api/PartitionedProducerConsumerTest.java       |   2 +-
 .../client/api/SimpleProducerConsumerTest.java     |   6 +-
 .../client/api/v1/V1_ProducerConsumerTest.java     |   8 +-
 .../client/impl/BrokerClientIntegrationTest.java   |   4 +-
 .../pulsar/client/impl/MessageChunkingTest.java    |  70 ++++---
 .../client/impl/MessagePublishThrottlingTest.java  |   3 +-
 .../pulsar/client/impl/MessageRedeliveryTest.java  | 223 ++++++++++-----------
 .../pulsar/client/impl/TopicsConsumerImplTest.java |   3 +-
 .../apache/pulsar/io/PulsarFunctionE2ETest.java    |   5 +-
 .../org/apache/pulsar/io/PulsarSinkE2ETest.java    |   4 +-
 .../websocket/proxy/ProxyAuthenticationTest.java   |   3 +-
 .../websocket/proxy/ProxyPublishConsumeTest.java   |   3 +-
 .../proxy/ProxyPublishConsumeTlsTest.java          |   3 +-
 .../proxy/ProxyPublishConsumeWithoutZKTest.java    |   3 +-
 .../proxy/v1/V1_ProxyAuthenticationTest.java       |   3 +-
 .../apache/pulsar/admin/cli/utils/IOUtilsTest.java |   3 +
 .../pulsar/client/cli/PulsarClientToolTest.java    |  10 +-
 .../pulsar/client/cli/PulsarClientToolWsTest.java  | 121 +++++------
 .../apache/pulsar/common/util/FutureUtilTest.java  |  18 +-
 .../collections/ConcurrentLongHashMapTest.java     |   9 +-
 .../collections/ConcurrentLongPairSetTest.java     |   9 +-
 .../collections/ConcurrentOpenHashMapTest.java     |   7 +-
 .../collections/ConcurrentOpenHashSetTest.java     |   7 +-
 .../ConcurrentSortedLongPairSetTest.java           |   4 +-
 .../GrowablePriorityLongPairQueueTest.java         |   7 +-
 .../pulsar/functions/instance/JavaInstance.java    |   4 +-
 .../functions/instance/JavaInstanceTest.java       |   5 +-
 .../org/apache/pulsar/functions/worker/Worker.java |   8 +-
 .../functions/worker/SchedulerManagerTest.java     |   4 +-
 .../bookkeeper/test/BookKeeperClusterTestCase.java |   2 +-
 .../bookkeeper/test/MockedBookKeeperTestCase.java  |   4 +-
 .../coordinator/test/MockedBookKeeperTestCase.java |   4 +-
 .../ZookeeperBkClientFactoryImplTest.java          |   2 +-
 .../pulsar/zookeeper/ZookeeperCacheTest.java       |  30 ++-
 62 files changed, 362 insertions(+), 341 deletions(-)