mridulm commented on code in PR #36165:
URL: https://github.com/apache/spark/pull/36165#discussion_r1062884659
##########
core/src/main/protobuf/org/apache/spark/status/protobuf/store_types.proto:
##########
@@ -652,6 +699,20 @@ message ShuffleReadMetricDistributions {
repeated double remote_bytes_read = 6;
repeated double remote_bytes_read_to_disk = 7;
repeated double total_blocks_fetched = 8;
+ repeated double remote_reqs_duration = 9;
+ ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
+}
+
+message ShufflePushReadMetricDistributions {
+ repeated double corrupt_merged_block_chunks = 1;
+ repeated double merged_fetch_fallback_count = 2;
+ repeated double remote_merged_blocks_fetched = 3;
+ repeated double local_merged_blocks_fetched = 4;
+ repeated double remote_merged_chunks_fetched = 5;
+ repeated double local_merged_chunks_fetched = 6;
+ repeated double remote_merged_bytes_read = 7;
+ repeated double local_merged_bytes_read = 8;
+ repeated double remote_merged_reqs_duration = 9;
}
Review Comment:
Thanks @gengliangwang !
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
