diff --git a/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java b/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java index 74ac9cf0..d2978436 100644 --- a/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java +++ b/common/src/main/java/ctbrec/recorder/NextGenLocalRecorder.java @@ -158,7 +158,7 @@ public class NextGenLocalRecorder implements Recorder { ScheduledFuture rescheduledFuture = downloadPool.schedule(rec, delay, TimeUnit.MILLISECONDS); downloadFutureQueue.add(rescheduledFuture); } else { - CompletableFuture.runAsync(() -> { + segmentDownloadPool.submit(() -> { deleteIfEmpty(rec); removeRecordingProcess(rec); if (rec.getStatus() == State.WAITING) {