diff --git a/relation_migrate/relation_migrate.migration.inc b/relation_migrate/relation_migrate.migration.inc
index 9fe3e99..8198c3b 100644
--- a/relation_migrate/relation_migrate.migration.inc
+++ b/relation_migrate/relation_migrate.migration.inc
@@ -39,6 +39,11 @@ abstract class RelationMigrateReference extends Migration {
           'unsigned' => TRUE,
           'not null' => TRUE,
         ),
+        'delta' => array(
+          'type' => 'int',
+          'unsigned' => TRUE,
+          'not null' => TRUE,
+        ),
       ),
       MigrateDestinationRelation::getKeySchema()
     );
diff --git a/relation_migrate/relation_migrate.source.inc b/relation_migrate/relation_migrate.source.inc
index 69a097b..2d96616 100644
--- a/relation_migrate/relation_migrate.source.inc
+++ b/relation_migrate/relation_migrate.source.inc
@@ -89,7 +89,7 @@ abstract class MigrateSourceReference extends MigrateSource {
 
       if (!empty($field_info) && $field_info['type'] == $this->field_type) {
         $field_data = db_select('field_data_' . $field_name, 'f')
-          ->fields('f', array('entity_type', 'entity_id', $field_name . '_' . $columns[0]))
+          ->fields('f', array('entity_type', 'entity_id', 'delta', $field_name . '_' . $columns[0]))
           ->condition('deleted', 0);
         $field_data->addExpression(":name", 'field_name', array(':name' => $field_name));
         $field_data = $field_data->execute()->fetchAll();
@@ -118,6 +118,7 @@ abstract class MigrateSourceReference extends MigrateSource {
         'destination_type' => $destination_type,
         'destination_id' => $item->{$id_key},
         'field_name' => $field_name,
+        'delta' => $item->delta, 
       );
 
       return (object)$ret;