diff --git a/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/NotifyOfRecordsDueForReviewJobExecuter.java b/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/NotifyOfRecordsDueForReviewJobExecuter.java
index 35f5db78c0..f611606969 100644
--- a/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/NotifyOfRecordsDueForReviewJobExecuter.java
+++ b/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/NotifyOfRecordsDueForReviewJobExecuter.java
@@ -93,8 +93,8 @@ public class NotifyOfRecordsDueForReviewJobExecuter extends RecordsManagementJob
                 StringBuilder queryBuffer = new StringBuilder();
                 queryBuffer.append("ASPECT:\"rma:vitalRecord\" ");
                 queryBuffer.append("AND @rma\\:reviewAsOf:[MIN TO NOW] ");
-                // exclude destroyed records with metadata
-                queryBuffer.append("AND (ISNOTNULL:\"cm:content\" OR TYPE:\"rma:nonElectronicDocument\")");
+                // exclude destroyed electronic records and destroyed nonElectronic records with kept metadata
+                queryBuffer.append("AND -ASPECT:\"rma:ghosted\" ");
                 String query = queryBuffer.toString();
 
                 ResultSet results = searchService.query(StoreRef.STORE_REF_WORKSPACE_SPACESSTORE, SearchService.LANGUAGE_FTS_ALFRESCO, query);