Skip to content

Commit

Permalink
reorder some metrics
Browse files Browse the repository at this point in the history
  • Loading branch information
@fuyufjh
fuyufjh committed Nov 2, 2023
1 parent b6743d6 commit 3615108
Showing 1 changed file with 52 additions and 53 deletions.
105 changes: 52 additions & 53 deletions grafana/risingwave-dev-dashboard.dashboard.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -908,20 +908,6 @@ def section_streaming_actors(outer_panels):
outer_panels.row_collapsed(
"Streaming Actors",
[
panels.timeseries_actor_rowsps(
"Executor Throughput",
"When enabled, this metric shows the input throughput of each executor.",
[
panels.target(
f"sum(rate({metric('stream_executor_row_count')}[$__rate_interval])) by (executor_identity, fragment_id)",
"{{executor_identity}} fragment {{fragment_id}}",
),
panels.target_hidden(
f"rate({metric('stream_executor_row_count')}[$__rate_interval])",
"{{executor_identity}} actor {{actor_id}}",
),
],
),
panels.timeseries_percentage(
"Actor Output Blocking Time Ratio (Backpressure)",
"We first record the total blocking duration(ns) of output buffer of each actor. It shows how "
Expand All @@ -934,45 +920,6 @@ def section_streaming_actors(outer_panels):
),
],
),
panels.timeseries_bytes(
"Actor Memory Usage (TaskLocalAlloc)",
"The actor-level memory usage statistics reported by TaskLocalAlloc. (Disabled by default)",
[
panels.target(
f"sum({metric('actor_memory_usage')}) by (fragment_id)",
"fragment {{fragment_id}}",
),
panels.target_hidden(
f"{metric('actor_memory_usage')}",
"actor {{actor_id}}",
),
],
),
panels.timeseries_bytes(
"Executor Memory Usage",
"The operator-level memory usage statistics collected by each LRU cache",
[
panels.target(
f"sum({metric('stream_memory_usage')}) by (table_id, desc)",
"table {{table_id}} desc: {{desc}}",
),
panels.target_hidden(
f"{metric('stream_memory_usage')}",
"table {{table_id}} actor {{actor_id}} desc: {{desc}}",
),
],
),

panels.timeseries_bytes(
"Materialized View Memory Usage",
"Memory usage aggregated by materialized views",
[
panels.target(
f"sum({metric('stream_memory_usage')} * on(table_id, actor_id) group_left(materialized_view_id) table_info) by (materialized_view_id)",
"mview {{materialized_view_id}}",
),
],
),
panels.timeseries_percentage(
"Actor Input Blocking Time Ratio",
"",
Expand Down Expand Up @@ -1011,6 +958,30 @@ def section_streaming_actors(outer_panels):
),
],
),
panels.timeseries_bytes(
"Executor Cache Memory Usage",
"The operator-level memory usage statistics collected by each LRU cache",
[
panels.target(
f"sum({metric('stream_memory_usage')}) by (table_id, desc)",
"table {{table_id}} desc: {{desc}}",
),
panels.target_hidden(
f"{metric('stream_memory_usage')}",
"table {{table_id}} actor {{actor_id}} desc: {{desc}}",
),
],
),
panels.timeseries_bytes(
"Executor Cache Memory Usage of Materialized Views",
"Memory usage aggregated by materialized views",
[
panels.target(
f"sum({metric('stream_memory_usage')} * on(table_id, actor_id) group_left(materialized_view_id) table_info) by (materialized_view_id)",
"materialized view {{materialized_view_id}}",
),
],
),
panels.timeseries_actor_ops(
"Join Executor Cache",
"",
Expand Down Expand Up @@ -1303,6 +1274,34 @@ def section_streaming_actors(outer_panels):
"over window cached count | table {{table_id}} actor {{actor_id}}"),
],
),
panels.timeseries_actor_rowsps(
"Executor Throughput",
"When enabled, this metric shows the input throughput of each executor.",
[
panels.target(
f"sum(rate({metric('stream_executor_row_count')}[$__rate_interval])) by (executor_identity, fragment_id)",
"{{executor_identity}} fragment {{fragment_id}}",
),
panels.target_hidden(
f"rate({metric('stream_executor_row_count')}[$__rate_interval])",
"{{executor_identity}} actor {{actor_id}}",
),
],
),
panels.timeseries_bytes(
"Actor Memory Usage (TaskLocalAlloc)",
"The actor-level memory usage statistics reported by TaskLocalAlloc. (Disabled by default)",
[
panels.target(
f"sum({metric('actor_memory_usage')}) by (fragment_id)",
"fragment {{fragment_id}}",
),
panels.target_hidden(
f"{metric('actor_memory_usage')}",
"actor {{actor_id}}",
),
],
),
],
)
]
Expand Down

0 comments on commit 3615108

Please sign in to comment.