aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2024-07-18 23:08:50 +0100
committerLuck <git@lucko.me>2024-07-18 23:08:50 +0100
commit39075341b53058f19ace303101aba68e2d7a6856 (patch)
treeb88c2fa30adcf358c0f68cace37e3e97e9c01638 /spark-common/src
parent8379f2b07bc38c24733c4f1d537ea7c2ee03d91b (diff)
downloadspark-39075341b53058f19ace303101aba68e2d7a6856.tar.gz
spark-39075341b53058f19ace303101aba68e2d7a6856.tar.bz2
spark-39075341b53058f19ace303101aba68e2d7a6856.zip
Add JVM information to viewer metadata
Diffstat (limited to 'spark-common/src')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java6
-rw-r--r--spark-common/src/main/proto/spark/spark.proto7
2 files changed, 13 insertions, 0 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 b0987c9..db6d177 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
@@ -101,6 +101,12 @@ public class PlatformStatisticsProvider {
.setVendorVersion(System.getProperty("java.vendor.version", "unknown"))
.setVmArgs(String.join(" ", runtimeBean.getInputArguments()))
.build()
+ )
+ .setJvm(SystemStatistics.Jvm.newBuilder()
+ .setName(System.getProperty("java.vm.name", "unknown"))
+ .setVendor(System.getProperty("java.vm.vendor", "unknown"))
+ .setVersion(System.getProperty("java.vm.version", "unknown"))
+ .build()
);
long uptime = runtimeBean.getUptime();
diff --git a/spark-common/src/main/proto/spark/spark.proto b/spark-common/src/main/proto/spark/spark.proto
index a70b3c3..53750d7 100644
--- a/spark-common/src/main/proto/spark/spark.proto
+++ b/spark-common/src/main/proto/spark/spark.proto
@@ -33,6 +33,7 @@ message SystemStatistics {
Java java = 6;
int64 uptime = 7;
map<string, NetInterface> net = 8;
+ Jvm jvm = 9;
message Cpu {
int32 threads = 1;
@@ -80,6 +81,12 @@ message SystemStatistics {
string vm_args = 4;
}
+ message Jvm {
+ string name = 1;
+ string vendor = 2;
+ string version = 3;
+ }
+
message NetInterface {
RollingAverageValues rx_bytes_per_second = 1;
RollingAverageValues tx_bytes_per_second = 2;