This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch experiment-ge.apache.org
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from c8e0ffe7bec Workaround compatibility issue
https://github.com/lhotari/gradle-enterprise-duplicate-test-id-repro
add a2ec02d7a34 [cleanup][broker] Fix ClusterDataImpl#clone and add test
(#19126)
add 3bb93cb95e6 [fix][broker][PIP-195] fix cursor skip read (#19124)
add 8790ed18fc0 [fix][monitor] Fix the partitioned publisher topic stat
aggregation bug (#18807)
add a6516a8d198 [fix][broker] Topic could be in fenced state forever if
deletion fails (#19129)
add 3afc29186a3 [improve][schema] Do not print error log with stacktrace
for 404 (#19130)
add 4b8f447d88d [feat][broker][PIP-195] Implement
BucketDelayedDeliveryTrackerFactory and load BucketDelayedDeliveryTracker -
part6 (#17756)
add 593fcb87b6d [improve][io] Elasticsearch sink: Support loading config
from secrets (#18986)
add 4028ad3d224 [improve][ci] Improve CI ssh access in forks, don't fail
build if setting up ssh access fails (#19127)
add c862356f624 [revert] "[fix][broker] change name limitTime to
limitTimeInSec (#19053)" (#19152)
add badd69b8e01 [fix][broker] fix ttl expiration block due to
no-recoverable exception even if autoSkipNonRecoverableData=true (#19132)
add 96f82627193 [improve][broker] Add oshi library to help control OS
resources. (#18990)
add 56a7b89be5f [fix][broker] Reject create non existent persistent
partitions. (#19086)
add b05fddb1af0 [improve][admin]internalGetMessageById shouldn't be
allowed on partitioned topic (#19013)
add 6335fa1efca [cleanup][txn] Use MLTransactionMetadataStore in
integration tests (#19140)
add e829672b84c [improve][broker] Add parameter check for create/update
cluster. (#19151)
add 90764e7a030 [fix][txn] Always send correct transaction id in end txn
response (#19137)
add 9ef54fd012e [improve][cli] Expose updateLocalTopicOnly to
UpdatePartitionedCmd (#19162)
add 827d20f8f99 Merge remote-tracking branch 'origin/master' into
experiment-ge.apache.org
add e4ad8077e41 Increase timeout to 75 minutes for "CI - Unit - Pulsar IO"
No new revisions were added by this update.
Summary of changes:
.github/actions/ssh-access/action.yml | 16 +-
.github/workflows/pulsar-ci-flaky.yaml | 1 +
.github/workflows/pulsar-ci.yaml | 11 +-
distribution/server/src/assemble/LICENSE.bin.txt | 8 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 10 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 62 +++-
pom.xml | 6 +
pulsar-broker/pom.xml | 6 +
.../apache/pulsar/broker/admin/AdminResource.java | 9 +-
.../pulsar/broker/admin/impl/ClustersBase.java | 17 +-
.../broker/admin/impl/PersistentTopicsBase.java | 363 ++++++++++-----------
.../broker/admin/impl/SchemasResourceBase.java | 5 +
.../pulsar/broker/admin/v1/PersistentTopics.java | 20 +-
.../pulsar/broker/admin/v1/SchemasResource.java | 20 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 20 +-
.../pulsar/broker/admin/v2/SchemasResource.java | 20 +-
...va => BucketDelayedDeliveryTrackerFactory.java} | 36 +-
.../delayed/DelayedDeliveryTrackerFactory.java | 9 +-
.../delayed/DelayedDeliveryTrackerLoader.java | 6 +-
.../InMemoryDelayedDeliveryTrackerFactory.java | 4 +-
.../pulsar/broker/service/BacklogQuotaManager.java | 4 +-
.../pulsar/broker/service/BrokerService.java | 23 +-
.../pulsar/broker/service/PulsarCommandSender.java | 2 +-
.../broker/service/PulsarCommandSenderImpl.java | 7 +-
.../apache/pulsar/broker/service/ServerCnx.java | 44 +--
.../broker/service/persistent/PersistentTopic.java | 21 +-
.../stats/prometheus/NamespaceStatsAggregator.java | 2 +-
.../pulsar/broker/EmbeddedPulsarCluster.java | 2 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 14 +-
.../pulsar/broker/admin/AdminApiClusterTest.java | 14 +
.../org/apache/pulsar/broker/admin/AdminTest.java | 6 +-
.../pulsar/broker/service/PersistentTopicTest.java | 65 +++-
.../service/ReplicatorTopicPoliciesTest.java | 2 +-
.../pulsar/broker/service/ServerCnxTest.java | 284 +++++++++++++++-
.../nonpersistent/NonPersistentTopicTest.java | 23 ++
...E2ETest.java => BucketDelayedDeliveryTest.java} | 19 +-
.../service/persistent/PersistentTopicTest.java | 20 ++
.../broker/service/utils/ClientChannelHelper.java | 35 +-
.../ZooKeeperSessionExpireRecoveryTest.java | 9 +-
.../MultiRolesTokenAuthorizationProviderTest.java | 3 +-
.../worker/PulsarFunctionPublishTest.java | 2 +-
.../apache/pulsar/io/AbstractPulsarE2ETest.java | 7 +-
.../pulsar/common/policies/data/BacklogQuota.java | 2 +-
.../policies/data/impl/BacklogQuotaImpl.java | 14 +-
.../org/apache/pulsar/admin/cli/CmdTopics.java | 6 +-
.../client/impl/TransactionMetaStoreHandler.java | 62 ++--
.../common/policies/data/ClusterDataImpl.java | 38 ++-
.../NonPersistentPartitionedTopicStatsImpl.java | 1 +
.../data/stats/NonPersistentTopicStatsImpl.java | 31 +-
.../data/stats/PartitionedTopicStatsImpl.java | 1 +
.../common/policies/data/stats/TopicStatsImpl.java | 29 +-
.../apache/pulsar/common/protocol/Commands.java | 16 +-
.../pulsar/common/util/URIPreconditions.java | 98 ++++++
.../common/policies/data/ClusterDataImplTest.java | 65 ++++
.../common/policies/data/ClusterDataTest.java | 77 +++++
.../NonPersistentPartitionedTopicStatsTest.java | 16 +-
.../policies/data/PersistentTopicStatsTest.java | 30 +-
.../pulsar/common/util/URIPreconditionsTest.java | 59 ++++
pulsar-io/elastic-search/pom.xml | 6 +
.../io/elasticsearch/ElasticSearchConfig.java | 7 +-
.../pulsar/io/elasticsearch/ElasticSearchSink.java | 2 +-
.../io/elasticsearch/ElasticSearchConfigTests.java | 71 ++--
.../metadata/impl/FaultInjectionMetadataStore.java | 20 +-
.../metadata/BacklogQuotaCompatibilityTest.java | 12 +-
.../proxy/server/ProxyWithAuthorizationTest.java | 6 +-
.../transaction/TransactionTestBase.java | 2 -
66 files changed, 1460 insertions(+), 468 deletions(-)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/{InMemoryDelayedDeliveryTrackerFactory.java
=> BucketDelayedDeliveryTrackerFactory.java} (52%)
copy
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/{PersistentFailoverStreamingDispatcherE2ETest.java
=> BucketDelayedDeliveryTest.java} (68%)
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/URIPreconditions.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/policies/data/ClusterDataImplTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/URIPreconditionsTest.java
