aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2022-01-30 10:57:54 +0000
committerLuck <git@lucko.me>2022-01-30 10:58:01 +0000
commitd35216ec6cfe39cc95ffe7bae4b57638e8cdd77b (patch)
treee427195a5698cfe81db3bf90746fb866eb36111b /spark-common/src/main/java/me
parent6dc107ae485d0897e028d529ed0c05568e2a0f77 (diff)
downloadspark-d35216ec6cfe39cc95ffe7bae4b57638e8cdd77b.tar.gz
spark-d35216ec6cfe39cc95ffe7bae4b57638e8cdd77b.tar.bz2
spark-d35216ec6cfe39cc95ffe7bae4b57638e8cdd77b.zip
Fix NPE in DiskUsage util (#166)
Diffstat (limited to 'spark-common/src/main/java/me')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/monitor/disk/DiskUsage.java8
1 files changed, 8 insertions, 0 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/monitor/disk/DiskUsage.java b/spark-common/src/main/java/me/lucko/spark/common/monitor/disk/DiskUsage.java
index 4450fcd..7a4ada4 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/monitor/disk/DiskUsage.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/monitor/disk/DiskUsage.java
@@ -44,6 +44,10 @@ public enum DiskUsage {
}
public static long getUsed() {
+ if (FILE_STORE == null) {
+ return 0;
+ }
+
try {
long total = FILE_STORE.getTotalSpace();
return total - FILE_STORE.getUsableSpace();
@@ -53,6 +57,10 @@ public enum DiskUsage {
}
public static long getTotal() {
+ if (FILE_STORE == null) {
+ return 0;
+ }
+
try {
return FILE_STORE.getTotalSpace();
} catch (IOException e) {