diff --git a/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java b/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java index b3b4fe48..8264e401 100644 --- a/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java +++ b/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java @@ -439,8 +439,9 @@ public class NextGenLocalRecorder implements Recorder { ppPool.shutdown(); client.shutdown(); downloadPool.awaitTermination(1, TimeUnit.MINUTES); - LOG.info("Waiting for post-processing to finish"); - ppPool.awaitTermination(10, TimeUnit.MINUTES); + int minutesToWait = 10; + LOG.info("Waiting {} minutes (max) for post-processing to finish", minutesToWait); + ppPool.awaitTermination(minutesToWait, TimeUnit.MINUTES); } catch (InterruptedException e) { Thread.currentThread().interrupt(); LOG.error("Error while waiting for pools to finish", e);