This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from e263e09 Fix replay topic policy message not work (#11136)
add d65a9fa Remove import regex format (#11144)
No new revisions were added by this update.
Summary of changes:
.../ManagedLedgerFactoryChangeLedgerPathTest.java | 2 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 6 ++-
.../AuthenticationProviderBasic.java | 6 ++-
.../AdditionalServletWithClassLoaderTest.java | 5 +-
.../broker/admin/AdminApiMaxUnackedMessages.java | 5 +-
.../OwnerShipForCurrentServerTestBase.java | 8 ++--
.../pulsar/broker/service/BatchMessageTest.java | 7 ++-
.../broker/service/PersistentQueueE2ETest.java | 8 +++-
.../pulsar/broker/service/ResendRequestTest.java | 7 ++-
.../pulsar/broker/service/ServerCnxTest.java | 3 +-
...ntStickyKeyDispatcherMultipleConsumersTest.java | 21 +++++++--
...ReplicatedSubscriptionsSnapshotBuilderTest.java | 5 +-
.../schema/AvroSchemaCompatibilityCheckTest.java | 2 +-
.../ProtobufSchemaCompatibilityCheckTest.java | 2 +-
.../StreamingEntryReaderTests.java | 10 +---
.../client/api/ClientDeduplicationFailureTest.java | 7 +--
.../api/PartitionedProducerConsumerTest.java | 6 ++-
.../pulsar/client/api/TlsProducerConsumerBase.java | 5 +-
...CountEquallyDivideBundleSplitAlgorithmTest.java | 7 ++-
.../java/org/apache/pulsar/admin/cli/CmdSinks.java | 7 ++-
.../org/apache/pulsar/client/cli/CmdConsume.java | 14 +++++-
.../org/apache/pulsar/client/impl/ReaderImpl.java | 13 +++++-
.../impl/ClientCnxRequestTimeoutQueueTest.java | 12 +++--
.../pulsar/client/impl/ClientTestFixtures.java | 3 +-
.../client/impl/ConsumerBuilderImplTest.java | 7 ++-
.../org/apache/pulsar/client/impl/HashTest.java | 3 +-
.../client/impl/MultiTopicsConsumerImplTest.java | 7 +--
.../client/impl/ProducerBuilderImplTest.java | 8 +++-
.../schema/generic/AbstractGenericSchemaTest.java | 4 +-
.../impl/schema/generic/GenericSchemaTest.java | 4 +-
.../config/validation/ValidatorImplsTest.java | 3 +-
.../pulsar/functions/instance/LogAppender.java | 5 +-
.../windowing/WindowFunctionExecutorTest.java | 53 ++++++++++++----------
.../functions/api/examples/serde/CustomObject.java | 5 +-
.../BasicKubernetesManifestCustomizer.java | 9 +++-
.../runtime/kubernetes/KubernetesRuntimeTest.java | 7 ++-
.../functions/utils/FunctionConfigUtils.java | 6 ++-
.../functions/utils/FunctionConfigUtilsTest.java | 6 ++-
.../worker/FunctionMetaDataManagerTest.java | 22 +++++++--
.../pulsar/io/batchdiscovery/CronTriggerer.java | 3 +-
.../pulsar/io/elasticsearch/ElasticSearchSink.java | 6 ++-
.../pulsar/io/flume/source/AbstractSource.java | 8 ++--
.../kafka/connect/AbstractKafkaConnectSource.java | 19 ++++++--
.../pulsar/sql/presto/TestPulsarConnector.java | 14 +++++-
.../sql/presto/decoder/avro/TestAvroDecoder.java | 14 +++++-
.../pulsar/testclient/ManagedLedgerWriter.java | 9 +++-
.../integration/SimpleProducerConsumerTest.java | 28 ++++++++----
.../integration/SimpleProducerConsumerTest.java | 32 ++++++++++---
.../integration/SimpleProducerConsumerTest.java | 28 ++++++++----
49 files changed, 353 insertions(+), 128 deletions(-)
