fengyubiao

[fix][flaky-test]TxnLogBufferedWriterTest.testMainProcess

1

Fixes #16989, #16723 Master Issue: #16989, #16723 ### Motivation - #16989: We mocked a BK error, but if an exception occurs, the failure callback will be executed earlier. So the...

[improve][txn] PIP-160 Metrics stats of Transaction buffered writer

17

Master Issue: #15370 ### Motivation see #15370 ### Modifications I will complete proposal #15370 with these pull requests( *current pull request is a part of step 7-1* ): 1. Write...

[fix][metrics]wrong metrics text generated when label_cluster specified

3

### Motivation If `label_cluster` specified `cluster_123`, the expected metrics text is: ``` metrics_xxx_total{cluster="cluster_123"} 1.0 ``` but the exactly metrics text is : ``` metrics_xxx_totalcluster="cluster_123"} 1.0 ``` High light: lost a...

[improve][txn]PIP-160 make txn components supports buffered writer metrics

2

Master Issue: #15370 ### Modifications - Make transaction `MLTransactionMetadataStoreProvider` & `MLPendingAckStoreProvider` support buffered writer metrics. - Motivation: #15370 ---- - Delete constructor of `TxnLogBufferedWriter` without parameter `metrics`. - Motivation: it...

[fix][broker]One topic can be close multiple times concurrently

15

### Motivation With the transaction feature, we send and receive messages, and at the same time, execute `admin API: unload namespace` 1000 times. Then the problem occur: Consumer could not...

[fix][ml]fix wrong cursor state if repeat do close

2

### Motivation Do ` curosr.close` twice. expect cursor state: `Closed` actual cursor state: `Closing` ### Modifications Fixed the state change logic ### Documentation - [ ] `doc` - [ ]...

[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...

Tracking issue for slow tests

3

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation This issue tracks efforts to optimize slow testing(which took more than 5 minutes),...

[fix][broker]fix Repeated messages of shared dispatcher

1

Fixes #16795 ### Motivation In `Shard` mode: 1. When redelivering some message, will trigger the next read. 1. When closing the lastest consumer or adding the first consumer, will trigger...

Fixes #18232 ### Motivation https://github.com/poorbarcode/pulsar/actions/runs/3267034877/jobs/5371836130 https://github.com/apache/pulsar/actions/runs/3242148385/jobs/5326408439 The original implementation determines whether to wait for the creation of `__chang_event` based on whether a broker has taken ownership of the bundle or...