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 ba58095 [ServerCnx] Close connection after receiving unexpected
SendCommand (#12780)
add d8260d4 [clean up] Delete unused imports (#12791)
No new revisions were added by this update.
Summary of changes:
.../pulsar/client/TlsProducerConsumerBase.java | 1 -
.../bookkeeper/mledger/impl/EntryCacheTest.java | 2 -
.../mledger/impl/ManagedLedgerFactoryTest.java | 8 ---
.../mledger/offload/OffloadersCacheTest.java | 1 -
.../bookkeeper/test/BookKeeperClusterTestCase.java | 1 -
.../bookkeeper/test/MockedBookKeeperTestCase.java | 1 -
.../broker/MockedBookKeeperClientFactory.java | 3 -
.../apache/pulsar/broker/SLAMonitoringTest.java | 2 -
.../broker/admin/AdminApiDelayedDelivery.java | 2 -
.../broker/admin/AdminApiMaxUnackedMessages.java | 1 -
.../pulsar/broker/admin/AdminApiSchemaTest.java | 1 -
.../apache/pulsar/broker/admin/AdminApiTest2.java | 1 -
.../pulsar/broker/admin/AdminApiTlsAuthTest.java | 1 -
.../apache/pulsar/broker/admin/BookiesApiTest.java | 1 -
.../broker/admin/BrokerAdminClientTlsAuthTest.java | 1 -
.../broker/admin/IncrementPartitionsTest.java | 1 -
.../pulsar/broker/admin/ResourceGroupsTest.java | 1 -
.../pulsar/broker/admin/TopicMessageTTLTest.java | 1 -
.../broker/admin/TopicPoliciesDisableTest.java | 1 -
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 1 -
.../broker/admin/v3/AdminApiTransactionTest.java | 1 -
.../apache/pulsar/broker/auth/AuthLogsTest.java | 1 -
.../broker/auth/AuthenticationServiceTest.java | 1 -
.../pulsar/broker/auth/AuthorizationTest.java | 1 -
.../InvalidBrokerConfigForAuthorizationTest.java | 1 -
.../loadbalance/LeaderElectionServiceTest.java | 1 -
.../loadbalance/SimpleLoadManagerImplTest.java | 4 +-
.../broker/lookup/http/v2/TopicLookupTest.java | 4 --
.../broker/namespace/NamespaceServiceTest.java | 1 -
.../broker/service/BacklogQuotaManagerTest.java | 1 -
.../pulsar/broker/service/BkEnsemblesTestBase.java | 1 -
.../broker/service/BrokerBookieIsolationTest.java | 1 -
.../service/BrokerServiceThrottlingTest.java | 5 --
.../pulsar/broker/service/BrokerTestBase.java | 1 -
...istentHashingStickyKeyConsumerSelectorTest.java | 3 -
.../broker/service/ConsumedLedgersTrimTest.java | 1 -
.../broker/service/EnableProxyProtocolTest.java | 1 -
.../pulsar/broker/service/MaxMessageSizeTest.java | 1 -
.../service/MessagePublishBufferThrottleTest.java | 6 +-
.../broker/service/NonPersistentTopicE2ETest.java | 2 -
.../PersistentDispatcherFailoverConsumerTest.java | 5 --
.../service/PersistentTopicConcurrentTest.java | 2 -
.../broker/service/PublishRateLimiterTest.java | 5 --
.../broker/service/ReplicatorRateLimiterTest.java | 1 -
.../pulsar/broker/service/ReplicatorTestBase.java | 1 -
.../pulsar/broker/service/ServerCnxTest.java | 1 -
.../SystemTopicBasedTopicPoliciesServiceTest.java | 3 -
.../pulsar/broker/service/TopicOwnerTest.java | 2 -
.../service/persistent/DelayedDeliveryTest.java | 1 -
.../service/persistent/MessageDuplicationTest.java | 1 -
.../PersistentTopicStreamingDispatcherE2ETest.java | 1 -
...roducerConsumerTestStreamingDispatcherTest.java | 1 -
.../pulsar/broker/stats/SubscriptionStatsTest.java | 1 -
.../NamespaceEventsSystemTopicServiceTest.java | 1 -
.../broker/transaction/TransactionConsumeTest.java | 1 -
.../pulsar/broker/transaction/TransactionTest.java | 5 --
.../transaction/buffer/TransactionBufferTest.java | 1 -
.../buffer/TransactionStablePositionTest.java | 8 ---
.../pendingack/PendingAckPersistentTest.java | 5 +-
.../apache/pulsar/broker/web/WebServiceTest.java | 2 -
.../ZooKeeperSessionExpireRecoveryTest.java | 1 -
.../AuthenticationTlsHostnameVerificationTest.java | 1 -
.../api/AuthorizationProducerConsumerTest.java | 2 -
.../client/api/MessageDispatchThrottlingTest.java | 1 -
.../pulsar/client/api/ProducerConsumerBase.java | 1 -
.../pulsar/client/api/ProducerQueueSizeTest.java | 4 --
...MultiListenersWithInternalListenerNameTest.java | 3 -
.../SubscriptionMessageDispatchThrottlingTest.java | 1 -
.../org/apache/pulsar/client/api/TenantTest.java | 1 -
.../TokenAuthenticatedProducerConsumerTest.java | 1 -
...kenOauth2AuthenticatedProducerConsumerTest.java | 1 -
.../client/api/v1/V1_ProducerConsumerBase.java | 1 -
.../client/impl/AdminApiKeyStoreTlsAuthTest.java | 1 -
.../client/impl/BrokerClientIntegrationTest.java | 6 --
.../client/impl/ConsumerConfigurationTest.java | 1 -
.../client/impl/DispatchAccordingPermitsTests.java | 1 -
...eyStoreTlsProducerConsumerTestWithAuthTest.java | 1 -
...toreTlsProducerConsumerTestWithoutAuthTest.java | 1 -
.../apache/pulsar/client/impl/LookupRetryTest.java | 3 +-
.../pulsar/client/impl/MessageParserTest.java | 1 -
.../pulsar/client/impl/NegativeAcksTest.java | 1 -
.../impl/PatternTopicsConsumerImplAuthTest.java | 1 -
.../pulsar/client/impl/ProducerSemaphoreTest.java | 3 -
.../apache/pulsar/client/impl/RawReaderTest.java | 1 -
.../pulsar/client/impl/SchemaDeleteTest.java | 1 -
.../pulsar/client/impl/TopicsConsumerImplTest.java | 1 -
.../pulsar/common/naming/NamespaceBundleTest.java | 4 --
.../pulsar/compaction/CompactionRetentionTest.java | 37 +----------
.../apache/pulsar/compaction/CompactionTest.java | 1 -
.../apache/pulsar/compaction/CompactorTest.java | 2 -
.../worker/PulsarFunctionE2ESecurityTest.java | 2 -
.../worker/PulsarFunctionLocalRunTest.java | 3 -
.../worker/PulsarFunctionMetadataStoreTest.java | 77 ----------------------
.../functions/worker/PulsarFunctionTlsTest.java | 1 -
.../worker/PulsarWorkerAssignmentTest.java | 2 -
.../apache/pulsar/io/AbstractPulsarE2ETest.java | 4 --
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 3 -
.../org/apache/pulsar/io/PulsarSinkE2ETest.java | 2 -
.../pulsar/schema/PartitionedTopicSchemaTest.java | 1 -
.../SchemaTypeCompatibilityCheckTest.java | 2 -
.../websocket/proxy/ProxyAuthorizationTest.java | 1 -
.../pulsar/client/cli/PulsarClientToolTest.java | 1 -
.../pulsar/client/cli/PulsarClientToolWsTest.java | 3 -
.../apache/pulsar/admin/cli/TestCmdClusters.java | 2 -
.../pulsar/client/impl/ConsumerImplTest.java | 1 -
.../client/impl/MultiTopicsConsumerImplTest.java | 2 -
.../apache/pulsar/client/impl/ReaderImplTest.java | 1 -
.../client/impl/TypedMessageBuilderImplTest.java | 1 -
.../client/impl/schema/KeyValueSchemaInfoTest.java | 2 -
.../client/impl/schema/KeyValueSchemaTest.java | 1 -
.../impl/schema/ProtobufNativeSchemaTest.java | 1 -
.../client/impl/schema/StringSchemaTest.java | 1 -
.../client/tutorial/ContinuousAsyncProducer.java | 1 -
.../pulsar/client/tutorial/ContinuousProducer.java | 1 -
.../client/tutorial/SampleAsyncProducer.java | 1 -
.../client/tutorial/SampleConsumerListener.java | 1 -
.../client/tutorial/SampleCryptoProducer.java | 1 -
.../pulsar/client/tutorial/SampleProducer.java | 1 -
.../CompressorCodecBackwardCompatTest.java | 1 -
.../NonPersistentPartitionedTopicStatsTest.java | 3 -
.../policies/data/PersistentTopicStatsTest.java | 4 --
.../impl/NamespaceIsolationPolicyImplTest.java | 2 -
.../common/util/ObjectMapperFactoryTest.java | 2 -
.../functions/instance/JavaInstanceRunnable.java | 1 -
.../pulsar/functions/instance/ContextImplTest.java | 1 -
.../state/PulsarMetadataStateStoreImplTest.java | 18 +----
.../pulsar/functions/source/PulsarSourceTest.java | 4 --
.../runtime/thread/ThreadRuntimeFactoryTest.java | 1 -
.../elasticsearch/ElasticSearchClientSslTests.java | 1 -
.../ElasticSearchSinkRawDataTests.java | 2 -
.../io/kafka/connect/KafkaConnectSinkTest.java | 2 -
.../connect/PulsarOffsetBackingStoreTest.java | 3 -
.../io/kafka/ByteBufferSchemaWrapperTest.java | 25 -------
.../pulsar/io/kafka/KafkaBytesSourceTest.java | 1 -
.../io/kafka/source/KafkaAbstractSourceTest.java | 6 --
.../apache/pulsar/io/mongodb/MongoSinkTest.java | 3 -
.../netty/tcp/NettyTCPChannelInitializerTest.java | 2 -
.../org/apache/pulsar/metadata/TestZKServer.java | 3 +-
.../proxy/server/AuthedAdminProxyHandlerTest.java | 1 -
.../InvalidProxyConfigForAuthorizationTest.java | 3 +-
.../ProxyAuthenticatedProducerConsumerTest.java | 1 -
.../server/ProxyWithAuthorizationNegTest.java | 1 -
.../proxy/server/ProxyWithAuthorizationTest.java | 1 -
.../server/ProxyWithJwtAuthorizationTest.java | 1 -
.../server/ProxyWithoutServiceDiscoveryTest.java | 1 -
.../SuperUserAuthedAdminProxyHandlerTest.java | 1 -
.../pulsar/sql/presto/TestCacheSizeAllocator.java | 1 -
.../pulsar/sql/presto/TestPulsarMetadata.java | 1 -
.../decoder/primitive/TestPrimitiveDecoder.java | 1 -
.../pulsar/testclient/PerformanceProducerTest.java | 1 -
.../testclient/TestDefaultMessageFormatter.java | 1 -
.../websocket/AbstractWebSocketHandlerTest.java | 1 -
.../zookeeper/LocalBookkeeperEnsembleTest.java | 2 -
.../slf4j/StructuredEventLogTest.java | 1 -
.../impl/FileSystemManagedLedgerOffloaderTest.java | 8 ---
.../jcloud/BlobStoreBackedInputStreamTest.java | 1 -
.../mledger/offload/jcloud/BlobStoreTestBase.java | 2 -
.../impl/BlobStoreManagedLedgerOffloaderBase.java | 8 ---
158 files changed, 11 insertions(+), 435 deletions(-)
