diff --git a/modules/salesforce_mapping/src/Commands/SalesforceMappingCommands.php b/modules/salesforce_mapping/src/Commands/SalesforceMappingCommands.php
index 9ac34a7c49d81e47147c8d4b6b434362640a8a41..3f8def96a66e60a93492e28c96c69dd056a9b816 100644
--- a/modules/salesforce_mapping/src/Commands/SalesforceMappingCommands.php
+++ b/modules/salesforce_mapping/src/Commands/SalesforceMappingCommands.php
@@ -214,7 +214,7 @@ class SalesforceMappingCommands extends SalesforceMappingCommandsBase {
       $entity_type = $this->etm->getDefinition($et_id);
       if ($entity_type) {
         $id_key = $entity_type->getKey('id');
-        $query->addJoin("LEFT", $entity_type->getBaseTable(), 'et', "et.$id_key = m.drupal_entity__target_id_int");
+        $query->addJoin("LEFT", $entity_type->getBaseTable(), 'et', "et.$id_key = m.drupal_entity__target_id");
         $query->isNull("et.$id_key");
       }
       $mapped_obj_ids = $query->execute()->fetchCol();