This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
omit 98cca0a Release 2.5.0
add 9aaf631 Add github actions ci workflow (#5642)
add 5504dc6 [transaction-coordinator] Implementation of transaction
coordinator client. (#5680)
add a8c8a7e Add more info in the error messages (#5714)
add 8a20d9a [Issue:4753] Add encryption docs to Functions develop (#5781)
add 702790a Bump version to 2.6.0 (#5820)
add 9a650a4 [build] Allow skipping deploying docker artifacts to maven
repo (#5821)
add 9231d4f Update website stable version to 2.4.2 (#5830)
add 9ece7a1 Ensure that the same message ID is not added to
UnAckedMessageTracker multiple times (#5823)
add 4bdec9b Change log level related to batch message timer to trace
(#5833)
add 8bcd0de Fix typo in functions-worker.md (#5838)
add c4a7091 [Issue 5708][docs] correct some wrong info about persistent
topics (#5789)
add b52449a [Issue 5827][Issue 5828][netty] Fixes for UDP protocol
support in netty connector (#5829)
add dfc8c1c Add a blog post for release 2.4.2 (#5824)
add 3bc8299 Provide better defaults for ingress tls and secretName
configuration. (#5859)
add e0942b8 [Doc][Issue 5397] Generate a complete list of connectors on
the Pulsar Download Page (#5852)
add a7e2f13 [Issue 5808][documentation]fix example code (#5814)
add 67fdfe2 Fixes some minor thread safety violations (#5793)
add 098ae44 Support batch authorization of partitioned topic (#5767)
add 3683b59 To fix the problem of repeated storage of offload driver
metadata. (#5834)
add 2d81c57 [pulsar-sql]Expose configurations of managed ledger and
bookkeeper client. (#5702)
add 9b55324 Provide raw counters metrics(#5802)
add fe0ddcc Fix flaky test for debezium (#5878)
add dc34ee1 Update missing import libs in function-develop.md (#5875)
add e5a9a66 [Issue 5839][website]Fix version replace for old version
document (#5865)
add 65cdc90 [release] Update 2.4.2 release blog (#5882)
add 3a2122b Fix pulsar build image with maven 3.6.1 (#5886)
add dc80d29 [docs]Refine "The Pulsar Java client" content (#5853)
add 0ec1abf [blog] Refine format issues for Pulsar 2.4.2 release blog
(#5893)
add bdb1f4c [blog] Add blog on Pulsar Summit CFP (#5888)
add b9aa4ce Fix Typo (#5864)
add a958098 fix 5825: make PulsarClusterMetadataSetup idempotent (#5879)
add e18463f [Issue 5857][Helm Chart] - Support to existing Storage Class
with StorageClassName (#5860)
add 5ffca81 fix some typos (#5889)
add 17e22d1 Added catch for NoClassDefFoundError wherever there was a
ClassNotFoundException (#5870)
add 805a421 [Pulsar Client Tools]Support generate documentation of pulsar
admin cli automatically (#5738)
add 880fb56 avoid unsafe split when validate hostname which might be ipv6
address (#5713)
add f7f2184 [Issue 5612] Use Reactivestreams client for Mongo Sink (#5635)
add 0607600 [Issue 5832][Pulsar IO]Fix npe of debezium delete event
(#5876)
add 5a9d35c Use BOOKIE_MEM and BOOKIE_GC env vars if set. (#5892)
add c635d08 [Issue:5669] Fix the ledgerID not found cause NPE (#5809)
add 616d459 Added `zookeeper.snapshot.trust.empty=true` for ZK 3.5
upgrade (#5855)
add a63f991 Fix read 0 entries cause message stop dispatch (#5894)
add d3f45ed Fix wrong redelivery count while redeliver when consumer
disconnected. (#5895)
add feeaa30 [Blog] Pulsar milestone celebration—200 contributors! (#5906)
add 602f518 [functions] Added default metrics for Prometheus (#5885)
add aa83ad3 Fix topic owner check while namespace bundles cache
invalidate. (#5919)
add 4ec754c Downgrade maven for license check (#5874)
add a2c9d4e Fix the download path of functions nar pkg (#5933)
add 6d6fcca Fix Javadoc comments in the pulsar-io-core module (#5884)
add 38839b6 [docs] Update C++ client libraries (#5945)
add 757d971 Add diskUsageThreshold to 0.99 (#5970)
add babce5e Vagrantfile update for build dependency (#5968)
add d6f90dd Fixes #5814: add SentConnectFrame state check when running
`handleError` (#5913)
add a26f67a [Issue 5454][pulsar-client-cpp]Fix cpp client schema version
(#5930)
add 1aa3299 [broker] Allow for namespace default of offload threshold
(#5872)
add c648981 Remove duplicated lombok annotations in the pulsar-io modules
(#5911)
add 4b57776 [Issue:5818]Set the startup order of broker and bookie (#5957)
add d98562d [proxy] Proxy doesn't use the right ca certicate to connect
to brokers (#5971)
add cff311c Update document for debezium (#5973)
add dcaa1d3 fix 2 copies of 3bookie and stop 2 booksie after production.
After the entire bookie is restored, it can be produced at this time, and the
produced data cannot be consumed normally. Restarting the broker can resume
normal (#5965)
add 5c58ff4 [pulsar-flink]Cache Pulsar client to make it shared among
tasks in a process (#5900)
add c7094c9 [Reopen][Issue 5597] Retry when getPartitionedTopicMetadata
failed (#5844)
add 88fc454 fix reader builder clone error (#5923)
add f95c71f Make standalone to advertise "localhost" to avoid failure
when hostname is not resolvable (#5856)
add 23ae5ec Make docker files consistent. (#5949)
add f141efa Make unit tests to only use dynamically allocated ports
(#5486)
new f2afad3 Release 2.5.0
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (98cca0a)
\
N -- N -- N refs/heads/branch-2.5 (f2afad3)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../workflows/ci-cpp.yaml | 49 ++-
.../ci-integration-backwards-compatibility.yaml | 42 +-
.../workflows/ci-integration-cli.yaml | 42 +-
.../workflows/ci-integration-function-state.yaml | 42 +-
.../workflows/ci-integration-messaging.yaml | 42 +-
.../workflows/ci-integration-process.yaml | 42 +-
.../workflows/ci-integration-schema.yaml | 42 +-
.../workflows/ci-integration-sql.yaml | 45 ++-
.../workflows/ci-integration-standalone.yaml | 42 +-
.../workflows/ci-integration-thread.yaml | 42 +-
.../ci-integration-tiered-filesystem.yaml | 42 +-
.../workflows/ci-integration-tiered-jcloud.yaml | 42 +-
.../workflows/ci-license.yaml | 60 +--
.github/workflows/ci-unit-flaky.yaml | 65 ++++
.github/workflows/ci-unit.yaml | 65 ++++
bin/pulsar | 2 +-
build/docker/Dockerfile | 15 +-
conf/bkenv.sh | 4 +-
conf/broker.conf | 8 +-
conf/functions_worker.yml | 2 +-
conf/presto/catalog/pulsar.properties | 29 ++
dashboard/pom.xml | 11 +
.../pulsar/templates/bookkeeper-statefulset.yaml | 8 +-
.../helm/pulsar/templates/broker-deployment.yaml | 13 +
.../helm/pulsar/templates/dashboard-ingress.yaml | 6 +-
.../helm/pulsar/templates/prometheus-pvc.yaml | 4 +-
.../pulsar/templates/zookeeper-statefulset.yaml | 4 +-
deployment/kubernetes/helm/pulsar/values.yaml | 48 ++-
dev/Vagrantfile | 1 +
distribution/server/src/assemble/LICENSE.bin.txt | 1 +
docker/pom.xml | 11 +
.../bookkeeper/mledger/ManagedLedgerException.java | 4 +
.../bookkeeper/mledger/impl/EntryCacheImpl.java | 19 +-
.../bookkeeper/mledger/impl/EntryCacheManager.java | 29 ++
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 11 +-
.../bookkeeper/mledger/impl/OpReadEntry.java | 6 +-
.../bookkeeper/mledger/offload/OffloadUtils.java | 13 +-
.../mledger/impl/EntryCacheManagerTest.java | 45 ++-
.../bookkeeper/mledger/impl/EntryCacheTest.java | 2 +-
.../mledger/offload/OffloadUtilsTest.java | 58 +++
.../bookkeeper/test/BookKeeperClusterTestCase.java | 4 +-
.../org/apache/bookkeeper/test/PortManager.java | 127 ------
.../org/apache/bookkeeper/test/ZooKeeperUtil.java | 14 +-
pom.xml | 1 +
protobuf-shaded/pom.xml | 2 +-
.../AuthenticationProviderAthenzTest.java | 26 +-
.../ProxySaslAuthenticationTest.java | 21 +-
.../authentication/SaslAuthenticateTest.java | 2 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 5 +
.../authorization/PulsarAuthorizationProvider.java | 20 +-
.../apache/pulsar/PulsarClusterMetadataSetup.java | 112 +++---
.../org/apache/pulsar/PulsarStandaloneStarter.java | 2 +-
.../org/apache/pulsar/broker/PulsarService.java | 14 +-
.../broker/TransactionMetadataStoreService.java | 85 +++-
.../broker/admin/impl/PersistentTopicsBase.java | 56 ++-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 2 +-
.../pulsar/broker/namespace/NamespaceService.java | 6 +-
.../pulsar/broker/service/AbstractTopic.java | 13 +
.../pulsar/broker/service/BrokerService.java | 8 +-
.../broker/service/BrokerServiceException.java | 5 +
.../org/apache/pulsar/broker/service/Consumer.java | 7 +-
.../broker/service/InMemoryRedeliveryTracker.java | 12 +
.../pulsar/broker/service/RedeliveryTracker.java | 4 +
.../broker/service/RedeliveryTrackerDisabled.java | 10 +
.../apache/pulsar/broker/service/ServerCnx.java | 84 +++-
.../service/nonpersistent/NonPersistentTopic.java | 2 +
.../PersistentDispatcherMultipleConsumers.java | 16 +-
.../PersistentDispatcherSingleActiveConsumer.java | 2 +-
.../service/persistent/PersistentReplicator.java | 2 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 145 +++----
.../broker/service/persistent/PersistentTopic.java | 2 +
.../stats/prometheus/NamespaceStatsAggregator.java | 3 +
.../pulsar/broker/stats/prometheus/TopicStats.java | 7 +
.../apache/pulsar/broker/SLAMonitoringTest.java | 47 ++-
.../pulsar/broker/admin/AdminApiOffloadTest.java | 2 +-
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 2 +-
.../pulsar/broker/admin/AdminApiSchemaTest.java | 2 +-
.../admin/AdminApiSchemaValidationEnforced.java | 2 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 50 +--
.../apache/pulsar/broker/admin/AdminApiTest2.java | 34 +-
.../pulsar/broker/admin/AdminApiTlsAuthTest.java | 6 +-
.../org/apache/pulsar/broker/admin/AdminTest.java | 13 +-
.../broker/admin/BrokerAdminClientTlsAuthTest.java | 21 +-
.../broker/admin/IncrementPartitionsTest.java | 2 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 63 ++-
.../pulsar/broker/admin/PersistentTopicsTest.java | 80 +++-
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 53 +--
.../pulsar/broker/admin/v1/V1_AdminApiTest2.java | 33 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 43 +-
.../AntiAffinityNamespaceGroupTest.java | 82 ++--
.../broker/loadbalance/LoadBalancerTest.java | 36 +-
.../loadbalance/ModularLoadManagerImplTest.java | 83 ++--
.../loadbalance/SimpleLoadManagerImplTest.java | 55 ++-
.../broker/service/AdvertisedAddressTest.java | 24 +-
.../broker/service/BacklogQuotaManagerTest.java | 22 +-
.../pulsar/broker/service/BkEnsemblesTestBase.java | 29 +-
.../broker/service/BrokerBkEnsemblesTests.java | 12 +-
.../broker/service/BrokerBookieIsolationTest.java | 52 +--
.../pulsar/broker/service/BrokerServiceTest.java | 59 +--
.../service/BrokerServiceThrottlingTest.java | 33 +-
.../pulsar/broker/service/MaxMessageSizeTest.java | 19 +-
.../pulsar/broker/service/PeerReplicatorTest.java | 3 +-
.../pulsar/broker/service/RackAwareTest.java | 9 +-
.../pulsar/broker/service/ReplicatorTest.java | 15 +-
.../pulsar/broker/service/ReplicatorTestBase.java | 70 ++--
.../pulsar/broker/service/TopicOwnerTest.java | 116 ++++++
.../broker/service/schema/ClientGetSchemaTest.java | 6 +-
.../schema/PartitionedTopicsSchemaTest.java | 2 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 14 +
.../TransactionCoordinatorAssignTest.java | 82 ----
.../TransactionCoordinatorClientTest.java | 63 +++
.../TransactionMetaStoreAssignmentTest.java | 73 ++++
.../coordinator/TransactionMetaStoreTestBase.java | 93 +++++
.../apache/pulsar/broker/web/WebServiceTest.java | 35 +-
.../broker/zookeeper/ClusterMetadataSetupTest.java | 58 +++
.../zookeeper/ZooKeeperClientAspectJTest.java | 30 +-
.../api/AuthenticatedProducerConsumerTest.java | 16 +-
.../AuthenticationTlsHostnameVerificationTest.java | 15 +-
.../api/AuthorizationProducerConsumerTest.java | 24 +-
.../pulsar/client/api/BrokerServiceLookupTest.java | 100 +++--
.../client/api/ClientDeduplicationFailureTest.java | 74 ++--
.../apache/pulsar/client/api/ClientErrorsTest.java | 60 ++-
.../pulsar/client/api/DeadLetterTopicTest.java | 6 +-
.../api/ExposeMessageRedeliveryCountTest.java | 65 +++-
.../pulsar/client/api/MockBrokerService.java | 69 ++--
.../client/api/MutualAuthenticationTest.java | 8 +-
.../pulsar/client/api/NonPersistentTopicTest.java | 53 ++-
.../pulsar/client/api/ProducerConsumerBase.java | 2 +-
.../pulsar/client/api/ServiceUrlProviderTest.java | 9 +-
.../client/api/SimpleProducerConsumerTest.java | 2 +-
.../pulsar/client/api/TlsHostVerification.java | 4 +-
.../pulsar/client/api/TlsProducerConsumerBase.java | 10 +-
.../pulsar/client/api/TlsProducerConsumerTest.java | 10 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 31 ++
.../client/api/v1/V1_ProducerConsumerBase.java | 2 +-
.../client/api/v1/V1_ProducerConsumerTest.java | 7 +-
.../client/impl/BrokerClientIntegrationTest.java | 12 +-
.../pulsar/client/impl/ConnectionPoolTest.java | 4 +-
.../client/impl/ConsumerConfigurationTest.java | 2 +-
.../client/impl/ConsumerUnsubscribeTest.java | 11 +-
.../pulsar/client/impl/MessageParserTest.java | 2 +-
.../client/impl/PulsarMultiHostClientTest.java | 158 ++++++++
.../apache/pulsar/client/impl/RawReaderTest.java | 2 +-
.../org/apache/pulsar/client/impl/ReaderTest.java | 10 +-
.../pulsar/client/impl/SchemaDeleteTest.java | 2 +-
.../client/impl/SequenceIdWithErrorTest.java | 2 +-
.../pulsar/compaction/CompactedTopicTest.java | 2 +-
.../apache/pulsar/compaction/CompactionTest.java | 2 +-
.../apache/pulsar/compaction/CompactorTest.java | 2 +-
.../service/web/DiscoveryServiceWebTest.java | 14 +-
.../worker/PulsarFunctionE2ESecurityTest.java | 69 ++--
.../worker/PulsarFunctionLocalRunTest.java | 210 +++++-----
.../worker/PulsarFunctionPublishTest.java | 86 ++--
.../worker/PulsarWorkerAssignmentTest.java | 53 ++-
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 36 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 127 +++---
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 31 +-
.../SchemaCompatibilityCheckTest.java | 2 +-
.../stats/client/PulsarBrokerStatsClientTest.java | 61 ---
.../websocket/proxy/ProxyAuthenticationTest.java | 18 +-
.../websocket/proxy/ProxyAuthorizationTest.java | 8 +-
.../websocket/proxy/ProxyConfigurationTest.java | 3 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 40 +-
.../proxy/ProxyPublishConsumeTlsTest.java | 14 +-
.../proxy/ProxyPublishConsumeWithoutZKTest.java | 9 +-
.../proxy/v1/V1_ProxyAuthenticationTest.java | 15 +-
pulsar-client-api/pom.xml | 17 +-
.../pulsar/client/api/PulsarClientException.java | 70 ++++
.../transaction/TransactionCoordinatorClient.java | 162 ++++++++
.../TransactionCoordinatorClientException.java | 121 ++++++
.../pulsar/client/internal/ReflectionUtils.java | 2 +-
pulsar-client-cpp/docker-build.sh | 9 +-
pulsar-client-cpp/docker-format.sh | 7 +-
pulsar-client-cpp/docker/build-client-lib.sh | 7 +-
pulsar-client-cpp/docker/build-wheels.sh | 12 +-
pulsar-client-cpp/include/pulsar/Result.h | 2 +
pulsar-client-cpp/lib/ClientConnection.cc | 6 +
pulsar-client-cpp/lib/ProducerImpl.cc | 3 +
pulsar-client-cpp/lib/Result.cc | 6 +
pulsar-client-cpp/tests/SchemaTest.cc | 3 +
.../clients/producer/PulsarKafkaProducer.java | 2 +-
.../pulsar/admin/cli/CmdGenerateDocument.java | 129 ++++++
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 1 +
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 3 +
.../client/impl/BinaryProtoLookupService.java | 11 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 44 ++-
.../apache/pulsar/client/impl/ConsumerBase.java | 2 -
.../pulsar/client/impl/ConsumerBuilderImpl.java | 7 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 76 +++-
.../client/impl/ConsumerStatsRecorderImpl.java | 4 +-
.../client/impl/MultiTopicsConsumerImpl.java | 3 +-
.../pulsar/client/impl/ProducerBuilderImpl.java | 3 +
.../apache/pulsar/client/impl/ProducerImpl.java | 44 ++-
.../pulsar/client/impl/PulsarClientImpl.java | 13 +-
.../pulsar/client/impl/ReaderBuilderImpl.java | 13 +-
.../client/impl/TransactionMetaStoreHandler.java | 433 +++++++++++++++++++++
.../pulsar/client/impl/UnAckedMessageTracker.java | 19 +-
...torClient.java => TransactionBufferClient.java} | 4 +-
...tImpl.java => TransactionBufferClientImpl.java} | 6 +-
.../TransactionCoordinatorClientImpl.java | 201 +++++++++-
.../apache/pulsar/client/impl/ClientCnxTest.java | 35 ++
.../pulsar/client/impl/ConnectionTimeoutTest.java | 12 +-
.../client/impl/UnAckedMessageTrackerTest.java | 77 ++++
.../apache/pulsar/common/api/proto/PulsarApi.java | 63 +++
.../apache/pulsar/common/nar/NarClassLoader.java | 4 +-
.../org/apache/pulsar/common/net/ServiceURI.java | 27 +-
.../pulsar/common/policies/data/TopicStats.java | 7 +
.../apache/pulsar/common/protocol/Commands.java | 33 +-
.../pulsar/common/protocol/PulsarDecoder.java | 8 +-
.../common/util/SslContextAutoRefreshBuilder.java | 2 +-
pulsar-common/src/main/proto/PulsarApi.proto | 4 +
.../apache/pulsar/common/net/ServiceURITest.java | 28 +-
.../discovery/service/BaseDiscoveryTestSetup.java | 15 +-
.../service/server/DiscoveryServiceWebTest.java | 12 +-
.../service/web/DiscoveryServiceWebTest.java | 31 +-
.../connectors/pulsar/CachedPulsarClient.java | 106 +++++
.../connectors/pulsar/FlinkPulsarProducer.java | 2 +-
.../connectors/pulsar/PulsarConsumerSource.java | 7 +-
.../connectors/pulsar/CachedPulsarClientTest.java | 103 +++++
.../pulsar/PulsarConsumerSourceTests.java | 2 +-
pulsar-functions/instance/pom.xml | 6 +
.../pulsar/functions/source/TopicSchema.java | 2 +-
.../windowing/WindowFunctionExecutor.java | 2 +-
.../functions/instance/JavaInstanceMain.java | 2 +-
.../functions/runtime/JavaInstanceStarter.java | 27 ++
.../pulsar/functions/utils/FunctionCommon.java | 8 +-
.../functions/utils/FunctionConfigUtils.java | 6 +-
.../apache/pulsar/functions/utils/Reflections.java | 14 +-
.../pulsar/functions/utils/SinkConfigUtils.java | 8 +-
.../pulsar/functions/utils/SourceConfigUtils.java | 8 +-
.../pulsar/functions/utils/ValidatorUtils.java | 8 +-
.../pulsar/io/aerospike/AerospikeSinkConfig.java | 6 +-
.../apache/pulsar/io/canal/CanalSourceConfig.java | 6 +-
.../pulsar/io/cassandra/CassandraSinkConfig.java | 6 +-
.../java/org/apache/pulsar/io/core/KeyValue.java | 2 +-
.../java/org/apache/pulsar/io/core/PushSource.java | 11 +-
.../main/java/org/apache/pulsar/io/core/Sink.java | 10 +-
.../org/apache/pulsar/io/core/SinkContext.java | 4 +
.../java/org/apache/pulsar/io/core/Source.java | 5 +-
.../org/apache/pulsar/io/core/SourceContext.java | 33 +-
.../pulsar/io/core/annotations/FieldDoc.java | 3 +-
.../io/elasticsearch/ElasticSearchConfig.java | 8 -
.../apache/pulsar/io/file/FileSourceConfig.java | 8 -
.../org/apache/pulsar/io/flume/FlumeConfig.java | 6 +-
.../node/PropertiesFileConfigurationProvider.java | 2 +-
.../pulsar/io/flume/source/StringSourceTests.java | 24 +-
.../pulsar/io/hbase/HbaseAbstractConfig.java | 8 -
.../pulsar/io/hbase/sink/HbaseAbstractSink.java | 8 -
.../pulsar/io/hbase/sink/HbaseSinkConfig.java | 6 -
.../io/hbase/sink/HbaseGenericRecordSinkTest.java | 4 -
.../apache/pulsar/io/hdfs2/AbstractHdfsConfig.java | 8 -
.../pulsar/io/hdfs2/AbstractHdfsConnector.java | 2 +-
.../pulsar/io/hdfs2/sink/HdfsSinkConfig.java | 6 -
.../apache/pulsar/io/hdfs3/AbstractHdfsConfig.java | 8 -
.../pulsar/io/hdfs3/AbstractHdfsConnector.java | 2 +-
.../pulsar/io/hdfs3/sink/HdfsSinkConfig.java | 6 -
.../pulsar/io/influxdb/InfluxDBSinkConfig.java | 8 -
.../io/influxdb/InfluxDBGenericRecordSinkTest.java | 2 -
.../org/apache/pulsar/io/jdbc/JdbcSinkConfig.java | 6 +-
.../java/org/apache/pulsar/io/jdbc/JdbcUtils.java | 9 -
.../org/apache/pulsar/io/jdbc/JdbcSinkTest.java | 6 +-
.../org/apache/pulsar/io/jdbc/SqliteUtils.java | 2 +-
.../io/kafka/connect/KafkaConnectSource.java | 8 +-
.../apache/pulsar/io/kafka/KafkaSinkConfig.java | 6 +-
.../apache/pulsar/io/kafka/KafkaSourceConfig.java | 6 +-
.../org/apache/pulsar/io/mongodb/MongoConfig.java | 6 +-
.../org/apache/pulsar/io/mongodb/MongoSink.java | 79 ++--
.../apache/pulsar/io/mongodb/MongoSinkTest.java | 60 +--
.../apache/pulsar/io/mongodb/MongoSourceTest.java | 9 +-
.../apache/pulsar/io/netty/NettySourceConfig.java | 8 -
.../apache/pulsar/io/netty/server/NettyServer.java | 21 +-
.../NettyTCPChannelInitializer.java} | 14 +-
.../NettyTCPServerHandler.java} | 22 +-
.../apache/pulsar/io/netty/tcp/package-info.java | 22 +-
.../NettyUDPChannelInitializer.java} | 14 +-
.../NettyUDPServerHandler.java} | 30 +-
.../apache/pulsar/io/netty/udp/package-info.java | 19 +-
.../netty/src/main/java/package-info.java | 18 -
.../NettyTCPChannelInitializerTest.java} | 21 +-
.../NettyUDPChannelInitializerTest.java} | 21 +-
.../pulsar/io/rabbitmq/RabbitMQAbstractConfig.java | 8 -
.../pulsar/io/rabbitmq/RabbitMQSinkConfig.java | 6 -
.../pulsar/io/rabbitmq/RabbitMQSourceConfig.java | 6 -
.../pulsar/io/redis/RedisAbstractConfig.java | 8 -
.../pulsar/io/redis/sink/RedisSinkConfig.java | 6 -
.../org/apache/pulsar/io/solr/SolrSinkConfig.java | 8 -
.../pulsar/io/solr/SolrGenericRecordSinkTest.java | 4 -
.../pulsar/io/twitter/TwitterFireHoseConfig.java | 8 -
.../pulsar/proxy/server/AdminProxyHandler.java | 2 +-
.../proxy/server/AuthedAdminProxyHandlerTest.java | 27 +-
.../ProxyAuthenticatedProducerConsumerTest.java | 21 +-
.../proxy/server/ProxyAuthenticationTest.java | 25 +-
.../server/ProxyConnectionThrottlingTest.java | 26 +-
.../proxy/server/ProxyForwardAuthDataTest.java | 41 +-
.../proxy/server/ProxyLookupThrottlingTest.java | 27 +-
.../pulsar/proxy/server/ProxyParserTest.java | 45 ++-
.../proxy/server/ProxyRolesEnforcementTest.java | 24 +-
.../org/apache/pulsar/proxy/server/ProxyTest.java | 25 +-
.../apache/pulsar/proxy/server/ProxyTlsTest.java | 13 +-
.../server/ProxyWithAuthorizationNegTest.java | 25 +-
.../proxy/server/ProxyWithAuthorizationTest.java | 48 ++-
.../server/ProxyWithoutServiceDiscoveryTest.java | 24 +-
.../SuperUserAuthedAdminProxyHandlerTest.java | 30 +-
.../server/UnauthedAdminProxyHandlerTest.java | 9 +-
pulsar-sql/presto-distribution/LICENSE | 1 +
.../pulsar/sql/presto/PulsarConnectorCache.java | 16 +-
.../pulsar/sql/presto/PulsarConnectorConfig.java | 73 ++++
.../pulsar/sql/presto/PulsarConnectorUtils.java | 2 +-
.../sql/presto/TestPulsarConnectorConfig.java | 19 +
.../pulsar/transaction/coordinator/TxnMeta.java | 2 +-
.../exceptions/CoordinatorException.java | 46 ++-
.../exceptions/InvalidTxnStatusException.java | 44 ---
.../impl/InMemTransactionMetadataStore.java | 4 +-
.../transaction/coordinator/impl/TxnMetaImpl.java | 7 +-
.../TransactionMetadataStoreProviderTest.java | 5 +-
.../pulsar/zookeeper/LocalBookkeeperEnsemble.java | 28 +-
.../zookeeper/LocalBookkeeperEnsembleTest.java | 64 +--
.../zookeeper/ZkBookieRackAffinityMappingTest.java | 14 +-
...kIsolatedBookieEnsemblePlacementPolicyTest.java | 16 +-
.../ZookeeperBkClientFactoryImplTest.java | 12 +-
.../zookeeper/ZookeeperClientFactoryImplTest.java | 8 +-
.../pulsar/zookeeper/ZookeeperServerTest.java | 13 +-
site2/docs/admin-api-persistent-topics.md | 96 +++--
site2/docs/client-libraries-cpp.md | 60 ++-
site2/docs/client-libraries-java.md | 205 +++++-----
site2/docs/functions-develop.md | 72 ++++
site2/docs/functions-worker.md | 2 +-
site2/docs/io-cdc-debezium.md | 45 ++-
site2/docs/io-debezium-source.md | 43 ++
site2/docs/reference-configuration.md | 4 +-
site2/docs/reference-metrics.md | 2 +
site2/docs/schema-get-started.md | 2 +-
site2/docs/schema-understand.md | 8 +-
.../website/blog/2019-12-04-Apache-Pulsar-2-4-2.md | 82 ++++
site2/website/blog/2019-12-18-Pulsar-summit-cfp.md | 43 ++
...2019-12-20-pulsar-milestone-200-contributors.md | 26 ++
site2/website/data/connectors.js | 112 ++++--
site2/website/scripts/replace.js | 9 +-
site2/website/static/img/cooperation.png | Bin 0 -> 181386 bytes
site2/website/static/img/p-200.png | Bin 0 -> 131947 bytes
.../version-2.3.0/io-cdc-debezium.md | 45 ++-
.../version-2.4.0/io-cdc-debezium.md | 43 ++
.../version-2.4.1/io-cdc-debezium.md | 43 ++
.../version-2.4.1/schema-understand.md | 12 +-
.../version-2.4.2/io-cdc-debezium.md | 44 +++
.../version-2.4.2/schema-understand.md | 8 +-
site2/website/versions.json | 2 +-
src/check-binary-license | 2 +-
.../apache/pulsar/tests/integration/SmokeTest.java | 3 +
.../apache/pulsar/tests/integration/SmokeTest.java | 3 +
.../pulsar/tests/integration/cli/CLITest.java | 27 ++
.../integration/functions/PulsarFunctionsTest.java | 100 ++++-
.../io/DebeziumMongoDbSourceTester.java | 37 ++
.../integration/io/DebeziumMySqlSourceTester.java | 43 +-
.../io/DebeziumPostgreSqlSourceTester.java | 34 +-
.../tests/integration/io/KafkaSourceTester.java | 15 +
.../pulsar/tests/integration/io/SourceTester.java | 27 +-
.../integration/topologies/PulsarCluster.java | 1 +
.../org/apache/pulsar/storm/PulsarBoltTest.java | 2 +-
.../org/apache/pulsar/storm/PulsarSpoutTest.java | 2 +-
360 files changed, 6688 insertions(+), 3260 deletions(-)
copy pulsar-client-cpp/docker-format.sh => .github/workflows/ci-cpp.yaml (50%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker-format.sh =>
.github/workflows/ci-integration-backwards-compatibility.yaml (51%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker/build-client-lib.sh =>
.github/workflows/ci-integration-cli.yaml (54%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker-format.sh =>
.github/workflows/ci-integration-function-state.yaml (52%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker/build-client-lib.sh =>
.github/workflows/ci-integration-messaging.yaml (53%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker/build-client-lib.sh =>
.github/workflows/ci-integration-process.yaml (53%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker/build-client-lib.sh =>
.github/workflows/ci-integration-schema.yaml (53%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker-format.sh =>
.github/workflows/ci-integration-sql.yaml (50%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker/build-client-lib.sh =>
.github/workflows/ci-integration-standalone.yaml (53%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker/build-client-lib.sh =>
.github/workflows/ci-integration-thread.yaml (53%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker-format.sh =>
.github/workflows/ci-integration-tiered-filesystem.yaml (52%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker/build-client-lib.sh =>
.github/workflows/ci-integration-tiered-jcloud.yaml (52%)
mode change 100755 => 100644
copy pulsar-client-cpp/docker-format.sh => .github/workflows/ci-license.yaml
(50%)
mode change 100755 => 100644
create mode 100644 .github/workflows/ci-unit-flaky.yaml
create mode 100644 .github/workflows/ci-unit.yaml
create mode 100644
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/offload/OffloadUtilsTest.java
delete mode 100644
managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TopicOwnerTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionCoordinatorAssignTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionCoordinatorClientTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreAssignmentTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/coordinator/TransactionMetaStoreTestBase.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/zookeeper/ClusterMetadataSetupTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PulsarMultiHostClientTest.java
create mode 100644
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClient.java
create mode 100644
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/transaction/TransactionCoordinatorClientException.java
create mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdGenerateDocument.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java
rename
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/{TransactionCoordinatorClient.java
=> TransactionBufferClient.java} (95%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/{TransactionCoordinatorClientImpl.java
=> TransactionBufferClientImpl.java} (90%)
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/UnAckedMessageTrackerTest.java
create mode 100644
pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java
create mode 100644
pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClientTest.java
copy
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/{server/NettyChannelInitializer.java
=> tcp/NettyTCPChannelInitializer.java} (72%)
copy
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/{server/NettyServerHandler.java
=> tcp/NettyTCPServerHandler.java} (82%)
rename
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/TransactionNotFoundException.java
=>
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/package-info.java
(59%)
rename
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/{server/NettyChannelInitializer.java
=> udp/NettyUDPChannelInitializer.java} (68%)
rename
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/{server/NettyServerHandler.java
=> udp/NettyUDPServerHandler.java} (75%)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/RedeliveryTracker.java
=>
pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/package-info.java
(68%)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/RedeliveryTracker.java
=> pulsar-io/netty/src/main/java/package-info.java (68%)
copy
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/{server/NettyChannelInitializerTest.java
=> tcp/NettyTCPChannelInitializerTest.java} (73%)
rename
pulsar-io/netty/src/test/java/org/apache/pulsar/io/netty/{server/NettyChannelInitializerTest.java
=> udp/NettyUDPChannelInitializerTest.java} (74%)
delete mode 100644
pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/InvalidTxnStatusException.java
create mode 100644 site2/website/blog/2019-12-04-Apache-Pulsar-2-4-2.md
create mode 100644 site2/website/blog/2019-12-18-Pulsar-summit-cfp.md
create mode 100644
site2/website/blog/2019-12-20-pulsar-milestone-200-contributors.md
create mode 100644 site2/website/static/img/cooperation.png
create mode 100644 site2/website/static/img/p-200.png
