aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2021-12-30 12:03:05 +0000
committerLuck <git@lucko.me>2021-12-30 12:03:05 +0000
commit2003a5c8dffa52d1bd8b923a0f899141ae816fbd (patch)
tree13c7840b73b06ae99bb293a9adbcda2492a432b3 /spark-common/src/main/java/me
parent22da90504795bf79e9acff893212b2c7c1de3392 (diff)
downloadspark-2003a5c8dffa52d1bd8b923a0f899141ae816fbd.tar.gz
spark-2003a5c8dffa52d1bd8b923a0f899141ae816fbd.tar.bz2
spark-2003a5c8dffa52d1bd8b923a0f899141ae816fbd.zip
Include JVM startup args
Diffstat (limited to 'spark-common/src/main/java/me')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java6
1 files changed, 5 insertions, 1 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java b/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java
index a9d83b2..a16c643 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java
@@ -32,6 +32,7 @@ import me.lucko.spark.proto.SparkProtos.SystemStatistics;
import java.lang.management.ManagementFactory;
import java.lang.management.MemoryUsage;
+import java.lang.management.RuntimeMXBean;
import java.util.Map;
public class PlatformStatisticsProvider {
@@ -42,6 +43,8 @@ public class PlatformStatisticsProvider {
}
public SystemStatistics getSystemStatistics() {
+ RuntimeMXBean runtimeBean = ManagementFactory.getRuntimeMXBean();
+
SystemStatistics.Builder builder = SystemStatistics.newBuilder()
.setCpu(SystemStatistics.Cpu.newBuilder()
.setThreads(Runtime.getRuntime().availableProcessors())
@@ -85,10 +88,11 @@ public class PlatformStatisticsProvider {
.setVendor(System.getProperty("java.vendor", "unknown"))
.setVersion(System.getProperty("java.version", "unknown"))
.setVendorVersion(System.getProperty("java.vendor.version", "unknown"))
+ .setVmArgs(String.join(" ", runtimeBean.getInputArguments()))
.build()
);
- long uptime = ManagementFactory.getRuntimeMXBean().getUptime();
+ long uptime = runtimeBean.getUptime();
builder.setUptime(uptime);
Map<String, GarbageCollectorStatistics> gcStats = GarbageCollectorStatistics.pollStats();