Skip to content

Commit

Permalink
fix(grafana): fix stream_join_matched_join_keys panel (risingwavelabs…
Browse files Browse the repository at this point in the history
  • Loading branch information
fuyufjh authored Jun 23, 2024
1 parent 785cf7f commit a3999da
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion docker/dashboards/risingwave-dev-dashboard.json

Large diffs are not rendered by default.

4 changes: 2 additions & 2 deletions grafana/risingwave-dev-dashboard.dashboard.py
Original file line number Diff line number Diff line change
Expand Up @@ -1294,14 +1294,14 @@ def section_streaming_actors(outer_panels):
"The number of matched rows on the opposite side",
[
*quantile(
lambda quantile, legend: panels.target(
lambda quantile, legend: panels.target_hidden(
f"histogram_quantile({quantile}, sum(rate({metric('stream_join_matched_join_keys_bucket')}[$__rate_interval])) by (le, fragment_id, table_id, {COMPONENT_LABEL}))",
f"p{legend} - fragment {{{{fragment_id}}}} table_id {{{{table_id}}}} - {{{{{COMPONENT_LABEL}}}}}",
),
[90, 99, "max"],
),
panels.target(
f"sum by(le, job, actor_id, table_id) (rate({metric('stream_join_matched_join_keys_sum')}[$__rate_interval])) / sum by(le, {COMPONENT_LABEL}, fragment_id, table_id) (rate({table_metric('stream_join_matched_join_keys_count')}[$__rate_interval])) >= 0",
f"sum by(le, {COMPONENT_LABEL}, fragment_id, table_id) (rate({metric('stream_join_matched_join_keys_sum')}[$__rate_interval])) / sum by(le, {COMPONENT_LABEL}, fragment_id, table_id) (rate({table_metric('stream_join_matched_join_keys_count')}[$__rate_interval])) >= 0",
"avg - fragment {{fragment_id}} table_id {{table_id}} - {{%s}}"
% COMPONENT_LABEL,
),
Expand Down
2 changes: 1 addition & 1 deletion grafana/risingwave-dev-dashboard.json

Large diffs are not rendered by default.

0 comments on commit a3999da

Please sign in to comment.