diff options
author | Luck <git@lucko.me> | 2021-07-18 21:31:32 +0100 |
---|---|---|
committer | Luck <git@lucko.me> | 2021-07-18 21:31:32 +0100 |
commit | 8204f693071ed7411300231cba8225b7846cc500 (patch) | |
tree | a6d6c4959b7280a3def22a43dbf7e2a3c6046bd9 /spark-common/src/main/java/me/lucko/spark/common/heapdump | |
parent | c31c7033318509e53c790f6cd6618cb94dca3af7 (diff) | |
download | spark-8204f693071ed7411300231cba8225b7846cc500.tar.gz spark-8204f693071ed7411300231cba8225b7846cc500.tar.bz2 spark-8204f693071ed7411300231cba8225b7846cc500.zip |
Add flag to save profile/heapsummary to files instead of uploading to bytebin
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.java | 16 |
1 files changed, 1 insertions, 15 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 de0c5df..34fd6c4 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 @@ -28,9 +28,6 @@ import me.lucko.spark.proto.SparkProtos.HeapEntry; import org.objectweb.asm.Type; -import java.io.ByteArrayOutputStream; -import java.io.IOException; -import java.io.OutputStream; import java.lang.management.ManagementFactory; import java.util.Arrays; import java.util.List; @@ -38,7 +35,6 @@ import java.util.Objects; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Collectors; -import java.util.zip.GZIPOutputStream; import javax.management.JMX; import javax.management.MBeanServer; @@ -129,7 +125,7 @@ public final class HeapDumpSummary { this.entries = entries; } - private HeapData toProto(PlatformInfo platformInfo, CommandSender creator) { + public HeapData toProto(PlatformInfo platformInfo, CommandSender creator) { HeapData.Builder proto = HeapData.newBuilder(); proto.setMetadata(SparkProtos.HeapMetadata.newBuilder() .setPlatformMetadata(platformInfo.toData().toProto()) @@ -144,16 +140,6 @@ public final class HeapDumpSummary { return proto.build(); } - public byte[] formCompressedDataPayload(PlatformInfo platformInfo, CommandSender creator) { - ByteArrayOutputStream byteOut = new ByteArrayOutputStream(); - try (OutputStream out = new GZIPOutputStream(byteOut)) { - toProto(platformInfo, creator).writeTo(out); - } catch (IOException e) { - throw new RuntimeException(e); - } - return byteOut.toByteArray(); - } - public static final class Entry { private final int order; private final int instances; |