Skip to content

[fix][broker]fix missing return when internalGetReplicatedSubscriptionStatus#7

Open
HQebupt wants to merge 1541 commits intomasterfrom
missReturn
Open

[fix][broker]fix missing return when internalGetReplicatedSubscriptionStatus#7
HQebupt wants to merge 1541 commits intomasterfrom
missReturn

Conversation

@HQebupt
Copy link
Owner

@HQebupt HQebupt commented Dec 25, 2022

Motivation

Fix missing return null if throw any exception when internalGetReplicatedSubscriptionStatus

Modifications

Add return null when handing exception in internalGetReplicatedSubscriptionStatus.

Verifying this change

  • Make sure that the change passes the CI checks.

Documentation

  • doc
  • doc-required
  • doc-not-needed
  • doc-complete

Matching PR in forked repository

PR in forked repository: #7

tisonkun and others added 30 commits November 16, 2022 00:38
* [Doc][Improve] Add landing pages

* Add tutorial pages

* Update site2/docs/about.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/install-deploy-upgrade-landing.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/install-deploy-upgrade-landing.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/install-deploy-upgrade-landing.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/install-deploy-upgrade-landing.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-tenant.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update developers-landing.md

* Create tutorials-produce-consume.md

* Update site2/docs/tutorials-tenant.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-tenant.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-tenant.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Delete developer-landing.md

* Update site2/docs/tutorials-tenant.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update install-deploy-upgrade-landing.md

* Update site2/docs/tutorials-topic.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-produce-consume.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-produce-consume.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-topic.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Typo

* Update site2/docs/tutorials-tenant.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-produce-consume.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-produce-consume.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-produce-consume.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/tutorials-namespace.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/install-deploy-upgrade-landing.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* Update site2/docs/how-to-landing.md

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>

* fix link and style issues

Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>
Co-authored-by: momo-jun <jma@streamnative.io>
apache#18343)

### Motivation

Authentication documentation has too many duplicate configurations and some unnecessary configurations.

Signed-off-by: Zixuan Liu <nodeces@gmail.com>
Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>
Fixes: apache#17921

<strong>Note</strong>: 

This patch will change metrics names `s_bufferedwriter_batch_record_count` and `s_bufferedwriter_batch_oldest_record_delay_time_second`. These two names were first used in this PR apache#17701, and PR apache#17701 hasn't cherry-picked any branches yet, so this change will not cause any breaking changes.

### Motivation

https://github.com/poorbarcode/pulsar/actions/runs/3156649582/jobs/5136584463
https://github.com/apache/pulsar/actions/runs/3156649597/jobs/5136596447

#### Problem-1

If the `Prometheus-Colloctor` which typed `Counter` is named 'xxx_count',  then the output `metrics-api` will be named 'xxx_count_count'.

`TxnLogBufferedWriterMetricsStats` hits this error.

https://github.com/apache/pulsar/blob/fb7307d8f4998e42b18df3a4599fd7ec34cb04a9/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/TxnLogBufferedWriterMetricsStats.java#L105-L106


----

#### Problem-2

`PrometheusMetricsTest` defines the standard metrics name(see code below): 

```
["_sum", "_bucket", "_count", "_total", "_created"]
```

But the standard Prometheus name has three others( see: https://github.com/prometheus/client_java/blob/c28b901225e35e7c1df0eacae8b58fdfbb390162/simpleclient/src/main/java/io/prometheus/client/Collector.java#L152-L186 ):

```
["_info", "_gsum", "_gcount"]
```


https://github.com/apache/pulsar/blob/fb7307d8f4998e42b18df3a4599fd7ec34cb04a9/pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java#L834-L861

----

### Modifications

- Make `PrometheusMetricsTest` run with transaction feature
- Make txn metrics name conforms to the rule. see: https://prometheus.io/docs/practices/naming/
- Make `PrometheusMetricsTest` support all suffix of prometheus metrics name

### Documentation

- [x] `doc-not-needed` 
(Please explain why)

### Matching PR in forked repository

PR in forked repository:

- poorbarcode#19
Signed-off-by: tison <wander4096@gmail.com>
Signed-off-by: tison <wander4096@gmail.com>
…tracker (apache#18392)


In addition, the `validationError` argument in
`newMessageAckCommandAndWrite` is never used.

### Modifications

Move the `isAckReceiptEnabled` into `ConsumerImpl` and add two methods `acquireReadLock`/`acquireWriteLock` to acquire the read or write lock if ACK receipt is enabled.

Remove the `validationError` argument.
Signed-off-by: Zixuan Liu <nodeces@gmail.com>
Signed-off-by: tison <wander4096@gmail.com>
Signed-off-by: tison <wander4096@gmail.com>
Co-authored-by: momo-jun <60642177+momo-jun@users.noreply.github.com>
…sage (apache#18511)

### Motivation

Currently, if there are duplicated messages whose chunk id is both 0, then it may result in allocating an unused buffer and may lead to the buffer memory leak.

### Modifications

* Only allocate the bytebuffer when there is no duplicated chunk message with chunk id 0.

Signed-off-by: Zike Yang <zike@apache.org>
lhotari and others added 25 commits December 20, 2022 20:19
…pache#18996)

Co-authored-by: gavingaozhangmin <gavingaozhangmin@didiglobal.com>
…meterized string formatting (apache#18968)

Co-authored-by: Ali Ahmed <alia@splunk.com>
Co-authored-by: fengwenzhi <fengwenzhi.max@bigo.sg>
@HQebupt
Copy link
Owner Author

HQebupt commented Dec 25, 2022

/pulsarbot rerun-failure-checks

@github-actions
Copy link

The pr had no activity for 30 days, mark with Stale label.

@github-actions github-actions bot added the Stale label Feb 19, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.