Skip to content

Commit 85ec43c

Browse files
authored
[data.dashboard] Fix broken Ray Data per node metrics because of unsupported operator filter (#57970)
## Description The per node metrics at OSS Ray Data dashboard are not displayed as expected. Because of this code change #55495, the following three metrics were added a filter for `operator`, which is [not supported](https://github.com/ray-project/ray/blob/e51f8039bc6992d37834bcff109a3d340e78fcde/python/ray/data/_internal/stats.py#L448) by per node metrics, and causes empty result. ray_data_num_tasks_finished_per_node ray_data_bytes_outputs_of_finished_tasks_per_node ray_data_blocks_outputs_of_finished_tasks_per_node Signed-off-by: cong.qian <cong.qian@anyscale.com>
1 parent 092550b commit 85ec43c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

python/ray/dashboard/modules/metrics/dashboards/data_dashboard_panels.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,7 @@
330330
unit="Bps",
331331
targets=[
332332
Target(
333-
expr='sum(rate(ray_data_bytes_outputs_of_finished_tasks_per_node{{{global_filters}, operator=~"$Operator"}}[1m])) by (dataset, node_ip)',
333+
expr="sum(rate(ray_data_bytes_outputs_of_finished_tasks_per_node{{{global_filters}}}[1m])) by (dataset, node_ip)",
334334
legend="Bytes output / Second: {{dataset}}, {{node_ip}}",
335335
)
336336
],
@@ -347,7 +347,7 @@
347347
unit="blocks/s",
348348
targets=[
349349
Target(
350-
expr='sum(rate(ray_data_blocks_outputs_of_finished_tasks_per_node{{{global_filters}, operator=~"$Operator"}}[1m])) by (dataset, node_ip)',
350+
expr="sum(rate(ray_data_blocks_outputs_of_finished_tasks_per_node{{{global_filters}}}[1m])) by (dataset, node_ip)",
351351
legend="Blocks output / Second: {{dataset}}, {{node_ip}}",
352352
)
353353
],
@@ -438,7 +438,7 @@
438438
unit="tasks/s",
439439
targets=[
440440
Target(
441-
expr='sum(rate(ray_data_num_tasks_finished_per_node{{{global_filters}, operator=~"$Operator"}}[1m])) by (dataset, node_ip)',
441+
expr="sum(rate(ray_data_num_tasks_finished_per_node{{{global_filters}}}[1m])) by (dataset, node_ip)",
442442
legend="Finished Tasks: {{dataset}}, {{node_ip}}",
443443
)
444444
],

0 commit comments

Comments
 (0)