diff options
| -rw-r--r-- | spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java b/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java index 5e25d91..f5886b5 100644 --- a/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java +++ b/spark-common/src/main/java/me/lucko/spark/common/SparkPlatform.java @@ -372,6 +372,10 @@ public class SparkPlatform { int warningIntervalSeconds = 5; try { + if (completed.get()) { + return; + } + for (int i = 1; i <= 3; i++) { try { Thread.sleep(warningIntervalSeconds * 1000); |