aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/common/heapdump
diff options
context:
space:
mode:
authorlucko <git@lucko.me>2024-08-06 21:29:48 +0100
committerGitHub <noreply@github.com>2024-08-06 21:29:48 +0100
commit8017dbd288fca21dac3813409dec959ae6e6c822 (patch)
treebce438e9a7156dcf04f99194295c753702600f1c /spark-common/src/main/java/me/lucko/spark/common/heapdump
parent613f702ddd8c1a7515298917a74464e6799df0c4 (diff)
downloadspark-8017dbd288fca21dac3813409dec959ae6e6c822.tar.gz
spark-8017dbd288fca21dac3813409dec959ae6e6c822.tar.bz2
spark-8017dbd288fca21dac3813409dec959ae6e6c822.zip
Add uploadable health report (#436)
Diffstat (limited to 'spark-common/src/main/java/me/lucko/spark/common/heapdump')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/heapdump/HeapDumpSummary.java17
1 files changed, 3 insertions, 14 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/heapdump/HeapDumpSummary.java b/spark-common/src/main/java/me/lucko/spark/common/heapdump/HeapDumpSummary.java
index 52140d5..a5e7039 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/heapdump/HeapDumpSummary.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/heapdump/HeapDumpSummary.java
@@ -22,6 +22,7 @@ package me.lucko.spark.common.heapdump;
import me.lucko.spark.common.SparkPlatform;
import me.lucko.spark.common.command.sender.CommandSender;
+import me.lucko.spark.common.platform.SparkMetadata;
import me.lucko.spark.proto.SparkHeapProtos.HeapData;
import me.lucko.spark.proto.SparkHeapProtos.HeapEntry;
import me.lucko.spark.proto.SparkHeapProtos.HeapMetadata;
@@ -130,20 +131,8 @@ public final class HeapDumpSummary {
}
public HeapData toProto(SparkPlatform platform, CommandSender.Data creator) {
- HeapMetadata.Builder metadata = HeapMetadata.newBuilder()
- .setPlatformMetadata(platform.getPlugin().getPlatformInfo().toData().toProto())
- .setCreator(creator.toProto());
- try {
- metadata.setPlatformStatistics(platform.getStatisticsProvider().getPlatformStatistics(null, true));
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- try {
- metadata.setSystemStatistics(platform.getStatisticsProvider().getSystemStatistics());
- } catch (Exception e) {
- e.printStackTrace();
- }
+ HeapMetadata.Builder metadata = HeapMetadata.newBuilder();
+ SparkMetadata.gather(platform, creator, platform.getStartupGcStatistics()).writeTo(metadata);
HeapData.Builder proto = HeapData.newBuilder();
proto.setMetadata(metadata);