diff --git a/src/main/java/ru/nbch/credit_tracker/service/signal/SignalRestService.java b/src/main/java/ru/nbch/credit_tracker/service/signal/SignalRestService.java
index 2b6143f..21c3db0 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/signal/SignalRestService.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/signal/SignalRestService.java
@@ -99,8 +99,6 @@ public class SignalRestService {
             } else {
                 log.error("неизвестная ошибка при постановке пакета на мониторинг в официальный сервис сигналов: {}", response.getBody());
             }
-            CTUtil.removeFile(path);
-            CTUtil.removeFile(path + ".gz");
             return false;
         }
         return false;
diff --git a/src/main/java/ru/nbch/credit_tracker/service/task/impl/XmlMergeCoordinator.java b/src/main/java/ru/nbch/credit_tracker/service/task/impl/XmlMergeCoordinator.java
index 232d6c0..087f6e3 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/task/impl/XmlMergeCoordinator.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/task/impl/XmlMergeCoordinator.java
@@ -51,6 +51,7 @@ public final class XmlMergeCoordinator implements IPipeLineTerminator<PartFilePa
     }
 
     private void mergeBatch(List<PartFilePayload> inputs) throws Exception {
+        log.debug("Starting merge batch; size: {}", inputs.size());
         Long packageId = inputs.stream().findFirst().get().getPackageId();
         String outName = "merged_" + packageId + ".xml";
         if (out == null) {
@@ -62,13 +63,15 @@ public final class XmlMergeCoordinator implements IPipeLineTerminator<PartFilePa
             XMLStreamWriter w = xof.createXMLStreamWriter(os, encoding.name());
 
             for (PartFilePayload in : inputs) {
-                log.debug("Copy person to file {}", in.getPartPath());
+                log.debug("Copy person from file {}", in.getPartPath());
                 copyPersonsChildren(in.getPartPath(), w);
             }
 
             w.flush();
             w.close();
         }
+        for (PartFilePayload p : inputs) Files.deleteIfExists(p.getPartPath());
+        inputs.clear();
     }
 
     /**
@@ -144,14 +147,14 @@ public final class XmlMergeCoordinator implements IPipeLineTerminator<PartFilePa
                         break;
                     }
                     if (p.isPoison()) {
-                        merge(batch);
+                        mergeBatch(batch);
                         done.complete(new SignalXmlFilePayload(out));
                         return;
                     }
                     batch.add(p);
                 }
                 if (!batch.isEmpty()) {
-                    merge(batch);
+                    mergeBatch(batch);
                 }
             } catch (InterruptedException ie) {
                 Thread.currentThread().interrupt();
@@ -161,12 +164,4 @@ public final class XmlMergeCoordinator implements IPipeLineTerminator<PartFilePa
             }
         }
     }
-
-    private void merge(List<PartFilePayload> inputs) throws Exception {
-        log.debug("Starting merge batch; size: {}", inputs.size());
-        mergeBatch(inputs);
-        //удаляем исходники после успешного мерджа
-        for (PartFilePayload p : inputs) Files.deleteIfExists(p.getPartPath());
-        inputs.clear();
-    }
 }