MC-31156: [GitHub] Error during migration when use prefix for tables #791

Author: victor-v-rad

src/Migration/Step/PostProcessing/Data/DeletedRecordsCounter.php

@@ -92,9 +92,11 @@ public function saveChanged($documents)
         $documentsToSave = [];
         $documents = array_unique(array_merge($this->deltaDocuments, $documents));
         foreach ($documents as $document) {
-            $recordsCountSource = $this->source->getRecordsCount(
-                $this->mapReader->getDocumentMap($document, MapInterface::TYPE_DEST)
-            );
+            $documentMap = $this->mapReader->getDocumentMap($document, MapInterface::TYPE_DEST);
+            if (!$documentMap) {
+                continue;
+            }
+            $recordsCountSource = $this->source->getRecordsCount($documentMap);
             $recordsCountDestination = $this->destination->getRecordsCount($document);
             if ($recordsCountSource != $recordsCountDestination) {
                 $documentsToSave[$document] = $recordsCountSource - $recordsCountDestination;