aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/common/heapdump
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2021-07-18 21:31:32 +0100
committerLuck <git@lucko.me>2021-07-18 21:31:32 +0100
commit8204f693071ed7411300231cba8225b7846cc500 (patch)
treea6d6c4959b7280a3def22a43dbf7e2a3c6046bd9 /spark-common/src/main/java/me/lucko/spark/common/heapdump
parentc31c7033318509e53c790f6cd6618cb94dca3af7 (diff)
downloadspark-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.java16
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;