You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2026/09/27 17:18:35 UTC
(pulsar) branch lh-dispatcher-lockfree-flow-master updated (e3a6f09209ea -> 3754d1e860a3)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch lh-dispatcher-lockfree-flow-master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
discard e3a6f09209ea [improve][broker] Apply Shared and Key_Shared Flow permits without the dispatcher monitor
discard a7c8d6a176d6 [improve][ml] Drain each add entry handover batch into a local list before running it
discard 710538d45b49 [improve][ml] Rename managedLedgerMaxAddEntryHandoverBatchSize to managedLedgerAddEntryHandoverMaxBatchSize
discard e30b242b55cd [improve][ml] Rename managedLedgerMaxAddBatchSize to managedLedgerMaxAddEntryHandoverBatchSize
discard bd31998eb505 [improve][ml] Make the maximum add batch size configurable with managedLedgerMaxAddBatchSize
discard 2b630eb28397 [improve][ml] Create the add batch queue lazily and name it for what it does
discard 69456a4d93f4 [improve][ml] Hand off adds to the managed-ledger executor through an MPSC queue
discard 745d7e06e35b [improve][test] Keep the Key_Shared 500x20 scenario saturating after the high-rate scenario got a rate limit
discard 67598923a189 [improve][test] Move the Key_Shared 500x20 scenarios to the restructured scenario settings
discard 2124c564869a [improve][test] Name the Key_Shared 500x20 runs after their scenario files
discard 485f73156487 [improve][test] Add a launcher scenario for 500 producers and a 20-member Key_Shared subscription
add e06bbda0dbb4 [improve][test] Collect the performance tests' Pulsar metrics into VictoriaMetrics and show them on Grafana's Pulsar dashboards
add 4f9168008bcb [fix][test] Address a review of the performance tests' profiling, heap dumps, sampling and metrics stack
add 094297dbe852 [improve][test] Add a launcher scenario for 500 producers and a 20-member Key_Shared subscription
add 20e33ad264d6 [improve][test] Name the Key_Shared 500x20 runs after their scenario files
add 963b755b7713 [improve][test] Move the Key_Shared 500x20 scenarios to the restructured scenario settings
add dfb674dd80f3 [improve][test] Keep the Key_Shared 500x20 scenario saturating after the high-rate scenario got a rate limit
add bcfa15a66652 [improve][ml] Hand off adds to the managed-ledger executor through an MPSC queue
add 6c890a4d1bbf [improve][ml] Create the add batch queue lazily and name it for what it does
add a72d93308cd2 [improve][ml] Make the maximum add batch size configurable with managedLedgerMaxAddBatchSize
add 30242e7b2ad4 [improve][ml] Rename managedLedgerMaxAddBatchSize to managedLedgerMaxAddEntryHandoverBatchSize
add b4b7f2d24c62 [improve][ml] Rename managedLedgerMaxAddEntryHandoverBatchSize to managedLedgerAddEntryHandoverMaxBatchSize
add d7fe05346c4f [improve][ml] Drain each add entry handover batch into a local list before running it
add 3754d1e860a3 [improve][broker] Apply Shared and Key_Shared Flow permits without the dispatcher monitor
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 (e3a6f09209ea)
\
N -- N -- N refs/heads/lh-dispatcher-lockfree-flow-master (3754d1e860a3)
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.
No new revisions were added by this update.
Summary of changes:
settings.gradle.kts | 2 +
.../integration/profiling/JonoffcpuAgent.java | 8 +-
tests/performance/AGENTS.md | 13 +-
tests/performance/README.md | 16 ++
tests/performance/docs/heap-dumps.md | 6 +-
tests/performance/docs/metrics.md | 222 +++++++++++++++
tests/performance/docs/run-reports.md | 7 +
tests/performance/docs/running-scenarios.md | 2 +
tests/performance/launcher/build.gradle.kts | 10 +
.../tests/performance/launcher/HeapDumper.java | 42 ++-
.../performance/launcher/MetricsCollection.java | 299 +++++++++++++++++++++
.../performance/launcher/MetricsSettings.java | 110 ++++++++
.../performance/launcher/PerformanceLauncher.java | 100 ++++++-
.../performance/launcher/TopicStatsSampler.java | 75 +++++-
.../performance/launcher/WorkloadStartup.java | 63 +++--
.../performance/launcher/HeapDumpSettingsTest.java | 13 +-
.../tests/performance/launcher/HeapDumperTest.java | 31 +++
.../performance/launcher/MetricsSettingsTest.java | 74 +++++
.../performance/launcher/WorkloadStartupTest.java | 21 ++
tests/performance/metrics/build.gradle.kts | 70 +++++
tests/performance/metrics/compose.yaml | 111 ++++++++
.../grafana/provisioning/dashboards/pulsar.yaml | 19 +-
.../provisioning/datasources/victoriametrics.yaml | 23 +-
tests/performance/metrics/grafana/setup.sh | 72 +++++
.../pulsar/tests/performance/metrics/Grafana.java | 109 ++++++++
.../tests/performance/metrics/GrafanaApi.java | 104 +++++++
.../tests/performance/metrics/MetricsCommand.java | 102 +++++++
.../tests/performance/metrics/MetricsStack.java | 205 ++++++++++++++
.../tests/performance/metrics/RunScrape.java | 109 ++++++++
.../tests/performance/metrics/ScrapeConfig.java | 91 +++++++
.../tests/performance/metrics}/package-info.java | 3 +-
.../performance/metrics/ScrapeConfigTest.java | 96 +++++++
.../metrics/victoriametrics/scrape.yaml | 16 +-
.../tests/performance/report/ReportsUrl.java | 3 +-
.../pulsar/tests/performance/report/RunReport.java | 54 +++-
.../tests/performance/report/RunReportTest.java | 47 ++++
tests/performance/scenarios/docs/iot-telemetry.md | 3 +-
.../performance/scenarios/docs/scenario-format.md | 2 +
.../performance/scenarios/iot-telemetry-base.yaml | 4 +
39 files changed, 2254 insertions(+), 103 deletions(-)
create mode 100644 tests/performance/docs/metrics.md
create mode 100644 tests/performance/launcher/src/main/java/org/apache/pulsar/tests/performance/launcher/MetricsCollection.java
create mode 100644 tests/performance/launcher/src/main/java/org/apache/pulsar/tests/performance/launcher/MetricsSettings.java
create mode 100644 tests/performance/launcher/src/test/java/org/apache/pulsar/tests/performance/launcher/MetricsSettingsTest.java
create mode 100644 tests/performance/metrics/build.gradle.kts
create mode 100644 tests/performance/metrics/compose.yaml
copy deployment/terraform-ansible/aws/ansible.cfg => tests/performance/metrics/grafana/provisioning/dashboards/pulsar.yaml (75%)
copy .github/actions/copy-test-reports/action.yml => tests/performance/metrics/grafana/provisioning/datasources/victoriametrics.yaml (67%)
create mode 100755 tests/performance/metrics/grafana/setup.sh
create mode 100644 tests/performance/metrics/src/main/java/org/apache/pulsar/tests/performance/metrics/Grafana.java
create mode 100644 tests/performance/metrics/src/main/java/org/apache/pulsar/tests/performance/metrics/GrafanaApi.java
create mode 100644 tests/performance/metrics/src/main/java/org/apache/pulsar/tests/performance/metrics/MetricsCommand.java
create mode 100644 tests/performance/metrics/src/main/java/org/apache/pulsar/tests/performance/metrics/MetricsStack.java
create mode 100644 tests/performance/metrics/src/main/java/org/apache/pulsar/tests/performance/metrics/RunScrape.java
create mode 100644 tests/performance/metrics/src/main/java/org/apache/pulsar/tests/performance/metrics/ScrapeConfig.java
copy {jclouds-shaded/src/main/java/org/apache/pulsar/jclouds => tests/performance/metrics/src/main/java/org/apache/pulsar/tests/performance/metrics}/package-info.java (83%)
create mode 100644 tests/performance/metrics/src/test/java/org/apache/pulsar/tests/performance/metrics/ScrapeConfigTest.java
copy deployment/terraform-ansible/aws/ansible.cfg => tests/performance/metrics/victoriametrics/scrape.yaml (74%)