Improve logging
This commit is contained in:
parent
5ecad75b0d
commit
5ac4241886
|
@ -439,8 +439,9 @@ public class NextGenLocalRecorder implements Recorder {
|
||||||
ppPool.shutdown();
|
ppPool.shutdown();
|
||||||
client.shutdown();
|
client.shutdown();
|
||||||
downloadPool.awaitTermination(1, TimeUnit.MINUTES);
|
downloadPool.awaitTermination(1, TimeUnit.MINUTES);
|
||||||
LOG.info("Waiting for post-processing to finish");
|
int minutesToWait = 10;
|
||||||
ppPool.awaitTermination(10, TimeUnit.MINUTES);
|
LOG.info("Waiting {} minutes (max) for post-processing to finish", minutesToWait);
|
||||||
|
ppPool.awaitTermination(minutesToWait, TimeUnit.MINUTES);
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
Thread.currentThread().interrupt();
|
Thread.currentThread().interrupt();
|
||||||
LOG.error("Error while waiting for pools to finish", e);
|
LOG.error("Error while waiting for pools to finish", e);
|
||||||
|
|
Loading…
Reference in New Issue