diff --git a/platform-tools/spikes/sync-tool/src/main/java/org/sunbird/sync/tool/mgr/BatchEnrolmentSyncManager.java b/platform-tools/spikes/sync-tool/src/main/java/org/sunbird/sync/tool/mgr/BatchEnrolmentSyncManager.java index 722ee697f7..838febae95 100644 --- a/platform-tools/spikes/sync-tool/src/main/java/org/sunbird/sync/tool/mgr/BatchEnrolmentSyncManager.java +++ b/platform-tools/spikes/sync-tool/src/main/java/org/sunbird/sync/tool/mgr/BatchEnrolmentSyncManager.java @@ -159,7 +159,7 @@ private void pushDocsToES(List rows, List docids, String index) thr String docId = docids.stream().map(key -> (String) docMap.get(key.toLowerCase())).collect(Collectors.toList()) .stream().collect(Collectors.joining("_")); - System.out.println(docMap); + //System.out.println(docMap); Map esDoc = new HashMap<>(); for(String key : docMap.keySet()){ String esKey = CassandraColumns.COLUMNS.get(key); @@ -173,7 +173,9 @@ private void pushDocsToES(List rows, List docids, String index) thr mapCertTemplate(esDoc); esDoc.put("identifier", docId); esDoc.put("id", docId); + System.out.println("ES DOC for : " + docId +" : " +esDoc); esDocs.put(docId, esDoc); + } if(MapUtils.isNotEmpty(esDocs)) { ElasticSearchUtil.bulkIndexWithIndexId(index, "_doc", esDocs);