ACPT-99

Author: aa-kashk

app/code/Magento/ImportExport/Model/Import.php

@@ -505,7 +505,7 @@ public function importSource()
 
         $result = $this->processImport();
         $this->getDataSourceModel()->markProcessedBunches($ids);
-        $this->getDataSourceModel()->cleanProcessedBunches();
+        $this->getDataSourceModel()->cleanBunchesWithId($ids);
         if ($result) {
             $this->addLogComment(
                 [

app/code/Magento/ImportExport/Model/ResourceModel/Import/Data.php

@@ -116,6 +116,22 @@ public function cleanBunches()
         return $this->getConnection()->delete($this->getMainTable());
     }
 
+    /**
+     * Clean bunches with specific Ids
+     *
+     * @param array $ids
+     * @return void
+     */
+    public function cleanBunchesWithId(array $ids)
+    {
+        $this->getConnection()->delete(
+            $this->getMainTable(),
+            [
+                'id IN (?)' => $ids,
+            ]
+        );
+    }
+
     /**
      * Clean all bunches from table.
      *