diff --git a/core/modules/migrate/src/Plugin/migrate/source/SourcePluginBase.php b/core/modules/migrate/src/Plugin/migrate/source/SourcePluginBase.php
index 6eb87c7..4ee6bfd 100644
--- a/core/modules/migrate/src/Plugin/migrate/source/SourcePluginBase.php
+++ b/core/modules/migrate/src/Plugin/migrate/source/SourcePluginBase.php
@@ -303,13 +303,12 @@ public function rewind() {
   public function next() {
     $this->currentSourceIds = NULL;
     $this->currentRow = NULL;
-    $source_configuration = $this->migration->get('source');
 
     // In order to find the next row we want to process, we ask the source
     // plugin for the next possible row.
     while (!isset($this->currentRow) && $this->getIterator()->valid()) {
 
-      $row_data = $this->getIterator()->current() + $source_configuration;
+      $row_data = $this->getIterator()->current() + $this->configuration;
       $this->getIterator()->next();
       $row = new Row($row_data, $this->migration->getSourcePlugin()->getIds(), $this->migration->get('destinationIds'));