diff --git a/process/DuplicateScanner_lib/process.js b/process/DuplicateScanner_lib/process.js
index f9c657b2ded81c3ee67d35b4670c1f5dae1f3226..085e9684fb9806792178b7177cb4a103751d81d2 100644
--- a/process/DuplicateScanner_lib/process.js
+++ b/process/DuplicateScanner_lib/process.js
@@ -100,10 +100,12 @@ DuplicateScannerUtils.GetCachedDuplicatesForContactId = function(pDuplicateId)
 
 DuplicateScannerUtils.GetCachedDuplicatesForClusterId = function(pClusterId)
 {
-    let query = "select DUPLICATEID from DUPLICATECLUSTERS"
-                + " where CLUSTERID = '"+ pClusterId +"' ";
-            
-    return db.array(db.COLUMN, query);
+    let duplicateIdsOfClusterWithoutUnrelated = SqlCondition.begin()
+    .and("DUPLICATEID not in (select UNRELATEDDUPLICATES.UNRELATEDDUPLICATEID from UNRELATEDDUPLICATES)")
+    .andIn("DUPLICATECLUSTERS.CLUSTERID", [pClusterId])
+    .buildSql("select DUPLICATEID from DUPLICATECLUSTERS");
+     
+    return db.array(db.COLUMN, duplicateIdsOfClusterWithoutUnrelated);
 }
 
 DuplicateScannerUtils.GetCachedDuplicatesForId = function(pClusterRecordId)