aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/monitor
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2018-11-02 20:02:58 +0000
committerLuck <git@lucko.me>2018-11-02 20:02:58 +0000
commitbd5056787953c0d59a3bab133d1c4eba7e2d398e (patch)
treee9cfff1647f61549e502eec9f964e6daaba4dfca /spark-common/src/main/java/me/lucko/spark/monitor
parent61f5addbb996f43d2044a4de12a8241584b8b65f (diff)
downloadspark-bd5056787953c0d59a3bab133d1c4eba7e2d398e.tar.gz
spark-bd5056787953c0d59a3bab133d1c4eba7e2d398e.tar.bz2
spark-bd5056787953c0d59a3bab133d1c4eba7e2d398e.zip
Add --without-gc flag (#7)
Diffstat (limited to 'spark-common/src/main/java/me/lucko/spark/monitor')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java8
1 files changed, 5 insertions, 3 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java b/spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java
index a7dd4a8..f3eb441 100644
--- a/spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java
+++ b/spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java
@@ -40,14 +40,14 @@ public abstract class TickMonitor implements Runnable, AutoCloseable {
private DoubleSummaryStatistics averageTickTime = new DoubleSummaryStatistics();
private double avg;
- public TickMonitor(TickCounter tickCounter, int percentageChangeThreshold) {
+ public TickMonitor(TickCounter tickCounter, int percentageChangeThreshold, boolean monitorGc) {
this.tickCounter = tickCounter;
this.percentageChangeThreshold = percentageChangeThreshold;
this.tickCounter.start();
this.tickCounter.addTickTask(this);
- this.garbageCollectionMonitor = new GarbageCollectionMonitor(this);
+ this.garbageCollectionMonitor = monitorGc ? new GarbageCollectionMonitor(this) : null;
}
protected abstract void sendMessage(String message);
@@ -55,7 +55,9 @@ public abstract class TickMonitor implements Runnable, AutoCloseable {
@Override
public void close() {
this.tickCounter.close();
- this.garbageCollectionMonitor.close();
+ if (this.garbageCollectionMonitor != null) {
+ this.garbageCollectionMonitor.close();
+ }
}
@Override