Merge pull request #1527 from PradyumnaNagendra/release-4.1.0

#SB-25799 fix: Coursebatch ES sync issue fix
Sunbird-Knowlg · Jul 20, 2021 · 604e85a · 604e85a
2 parents e2aed48 + 6a00764
commit 604e85a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...s/spikes/sync-tool/src/main/java/org/sunbird/sync/tool/mgr/BatchEnrolmentSyncManager.java b/...s/spikes/sync-tool/src/main/java/org/sunbird/sync/tool/mgr/BatchEnrolmentSyncManager.java
@@ -159,7 +159,7 @@ private void pushDocsToES(List<Row> rows, List<String> 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<String, Object> esDoc = new HashMap<>();
                 for(String key : docMap.keySet()){
                     String esKey = CassandraColumns.COLUMNS.get(key);
@@ -173,7 +173,9 @@ private void pushDocsToES(List<Row> rows, List<String> 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);