diff --git a/CRM/Mailing/BAO/MailingJob.php b/CRM/Mailing/BAO/MailingJob.php
index 0d49819d6408..0d91f4a60fd7 100644
--- a/CRM/Mailing/BAO/MailingJob.php
+++ b/CRM/Mailing/BAO/MailingJob.php
@@ -402,7 +402,7 @@ public function split_job($offset = 200) {
     $recipient_count = CRM_Mailing_BAO_Recipients::mailingSize($this->mailing_id);
 
     $jobTable = CRM_Mailing_DAO_MailingJob::getTableName();
-
+    $transaction = new CRM_Core_Transaction();
     $dao = new CRM_Core_DAO();
 
     $sql = "
@@ -437,6 +437,7 @@ public function split_job($offset = 200) {
         CRM_Core_DAO::executeQuery($sql, $params);
       }
     }
+    $transaction->commit();
   }
 
   /**