diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm
index 56391e3..2b4f31c 100644
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/accounting/cdr.pm
@@ -473,8 +473,11 @@ sub _get_export_stmt_part {
         if ('b' eq lc($static_context->{part})) {
             push @conds, $table . '.id > ' . $static_context->{last_processed_cdr_id};
         } elsif ('a' eq lc($static_context->{part}))  {
-            push @intjoins, 'LEFT JOIN ' . $db->tableidentifier(NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::gettablename()) . ' AS __cesd ON __cesd.cdr_id = ' . $table . '.id AND __cesd.status_id = ' . $static_context->{export_status_id};
-            push @conds, $table . '.id <= ' . $static_context->{last_processed_cdr_id};
+            $stmt = "FROM " . $db->tableidentifier(NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::gettablename())
+                . ' AS __cesd FORCE INDEX (PRIMARY)';
+            unshift @intjoins, 'LEFT JOIN ' . $table . ' FORCE INDEX (PRIMARY) ON ' . $table . '.id = __cesd.cdr_id';
+            push @conds, '__cesd.cdr_id <= ' . $static_context->{last_processed_cdr_id};
+            push @conds, '__cesd.status_id = ' . $static_context->{export_status_id};
             push @conds, '__cesd.export_status = "' . $NGCP::BulkProcessor::Dao::Trunk::accounting::cdr_export_status_data::UNEXPORTED . '"';
         }
     }