diff --git a/src/Plugin/migrate/source/d7/Subscriber.php b/src/Plugin/migrate/source/d7/Subscriber.php
index 59ed39d..1fccaa9 100644
--- a/src/Plugin/migrate/source/d7/Subscriber.php
+++ b/src/Plugin/migrate/source/d7/Subscriber.php
@@ -58,11 +58,11 @@ class Subscriber extends DrupalSqlBase {
     }
 
     // Add associated data from the subscriptions table.
-    $subscriptions = $this->select('simplenews_subscription', 'sub')
-      ->fields('sub', [$newsletter_id_field, 'status', 'timestamp', 'source'])
-      ->condition('sub.snid', $row->getSourceProperty('snid'))
-      ->execute()
-      ->fetchAllAssoc('newsletter_id');
+    $q = $this->select('simplenews_subscription', 'sub');
+    $q->addField('sub', $newsletter_id_field, 'newsletter_id');
+    $q->fields('sub', ['status', 'timestamp', 'source']);
+    $q->condition('sub.snid', $row->getSourceProperty('snid'));
+    $subscriptions = $q->execute()->fetchAllAssoc('newsletter_id');
     $row->setSourceProperty('subscriptions', $subscriptions);
 
     return $result;