pulsar

pulsar copied to clipboard

[fix][test] fix testEndTxnWhenCommittingOrAborting flaky test

1

issue: https://github.com/apache/pulsar/actions/runs/3383985489/jobs/5620564078 ### Motivation Transaction op count update after the write response, so we need to wait for the change to succeed https://github.com/congbobo184/pulsar/blob/2b441bd2ab4b71d5bc182f85c62fbea633c4ce4b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java#L314-L317 https://github.com/congbobo184/pulsar/blob/2b441bd2ab4b71d5bc182f85c62fbea633c4ce4b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java#L334-L337 ### Modifications wait count changed ###...

congbobo184

[doc][monitor]batch metadata store metrics doc

2

### Motivation doc for https://github.com/apache/pulsar/pull/17072 ### Documentation Check the box below or label this PR directly. Need to update docs? - [ ] `doc-required` (Your PR needs to update docs...

tjiuming

[refactor][doc] Refactor the information architecture of Schema topics

2

### Motivation Improve the doc set of the Schema chapter to provide Pulsar users with a more accurate, easy-to-read, and comprehensive information experience. Fixes #18151 ### Modifications 1. Curate a...

momo-jun

Add observability metrics for CommandPartitionedTopicMetadata requests

7

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently, there's no way to track CommandPartitionedTopicMetadata requests. There's no metrics or logs...

lhotari

[cleanup][txn] Avoid unnessary method call if txn disabled.

3

Fixes #18324 ### Motivation avoid unnecessary method call if txn disabled. ### Modifications 1. remove `isTxnEnabled` parameter in `TransactionBuffer.checkIfTransactionBufferRecoverCompletely`. 2. check isTxnEnabled before call txn related code in common code...

lifepuzzlefun

[improve][broker] Code simplify in `AbstractBaseDispatcher` in filterEntriesForConsumer loop

1

Fixes #18328 ### Modifications 1. batch `subscription.acknowledgeMesage` in filterEntriesForConsumer loop 2. remove unnecessary Optional package parameter for `filterEntriesForConsumer` metadataArray 3. avoid call O(consumer) times of `topic.getMigratedClusterUrl` in `checkAndApplyReachedEndOfTopicOrTopicMigration` ### Verifying...

lifepuzzlefun

Flaky-test: PersistentTopicStreamingDispatcherE2ETest.testMessageRedelivery

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/actions/runs/3377038718/jobs/5605505912#step:8:1667 ### Exception stacktrace Full exception stacktrace Error: testMessageRedelivery(org.apache.pulsar.broker.service.persistent.PersistentTopicStreamingDispatcherE2ETest) Time elapsed: 1.14...

coderzc

### Motivation This is a WIP to address recently noticed or reported issues regarding doc gaps. ### Modifications 1. Clarify the difference between the new S3 offloader and AWS S3...

momo-jun

### Motivation In `org.apache.pulsar.broker.admin.AdminResource#internalCreatePartitionedTopic`: - some logical order can be optimized. For example, can first execute `validateNamespaceOperation` for permission verification. - some log printing can be merged.see line 613,622,655 https://github.com/apache/pulsar/blob/2bed5ff3ab9dbb8c57c0d4d29a5a6775a610d326/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java#L613-L623...

Pomelongan

[fix][txn]Make txn metrics name conforms to the rule

2

Fixes: #17921 Note: This patch will change metrics name `s_bufferedwriter_batch_record_count` and `s_bufferedwriter_batch_oldest_record_delay_time_second`. These two names were first used in this PR #17701, and will be released in version `2.11.1`, so...

poorbarcode