aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/common/command
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2021-09-26 10:05:13 +0100
committerLuck <git@lucko.me>2021-09-26 10:05:13 +0100
commit89bd36f6cd9859ee8d7f6d9d51620326d678b457 (patch)
treea4fc6c57b87b539fd6921ae8d9b3df62de7e26ad /spark-common/src/main/java/me/lucko/spark/common/command
parentabc2eaa49f928a064ab3f197f3d9d8e3d16f2eb8 (diff)
downloadspark-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.java2
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) -> {