diff options
author | Luck <git@lucko.me> | 2021-09-26 10:05:13 +0100 |
---|---|---|
committer | Luck <git@lucko.me> | 2021-09-26 10:05:13 +0100 |
commit | 89bd36f6cd9859ee8d7f6d9d51620326d678b457 (patch) | |
tree | a4fc6c57b87b539fd6921ae8d9b3df62de7e26ad /spark-common/src/main/java/me/lucko/spark/common/command | |
parent | abc2eaa49f928a064ab3f197f3d9d8e3d16f2eb8 (diff) | |
download | spark-89bd36f6cd9859ee8d7f6d9d51620326d678b457.tar.gz spark-89bd36f6cd9859ee8d7f6d9d51620326d678b457.tar.bz2 spark-89bd36f6cd9859ee8d7f6d9d51620326d678b457.zip |
Support --timeout flag for async-profiler sampler mode
Diffstat (limited to 'spark-common/src/main/java/me/lucko/spark/common/command')
-rw-r--r-- | spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java b/spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java index c0a295a..4147de3 100644 --- a/spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java +++ b/spark-common/src/main/java/me/lucko/spark/common/command/modules/SamplerModule.java @@ -231,7 +231,7 @@ public class SamplerModule implements CommandModule { resp.broadcastPrefixed(text("The results will be automatically returned after the profiler has been running for " + timeoutSeconds + " seconds.")); } - CompletableFuture<? extends Sampler> future = this.activeSampler.getFuture(); + CompletableFuture<Sampler> future = this.activeSampler.getFuture(); // send message if profiling fails future.whenCompleteAsync((s, throwable) -> { |