fix:[NEXT-1893] Skip the AssetType if the ES throws exception (#2381)

Author: arunpaladin

jobs/pacman-data-shipper/src/main/java/com/tmobile/cso/pacman/datashipper/es/ESManager.java

@@ -452,7 +452,7 @@ public static void configureIndexAndTypes(String ds, List<Map<String, String>> e
      * @param filters   the filters
      * @return the existing info
      */
-    public static Map<String, Map<String, String>> getExistingInfo(String indexName, String type, List<String> filters) {
+    public static Map<String, Map<String, String>> getExistingInfo(String indexName, String type, List<String> filters) throws Exception {
         int count = getTypeCount(indexName, type);
         int _count = count;
         boolean scroll = false;
@@ -499,7 +499,7 @@ public static Map<String, Map<String, String>> getExistingInfo(String indexName,
      * @return the string
      */
     private static String fetchDataAndScrollId(String endPoint, Map<String, Map<String, String>> _data, String keyField,
-                                               String payLoad) {
+                                               String payLoad) throws Exception {
         try {
             ObjectMapper objMapper = new ObjectMapper();
             Response response = invokeAPI("GET", endPoint, payLoad);
@@ -519,8 +519,9 @@ private static String fetchDataAndScrollId(String endPoint, Map<String, Map<Stri
             return scrollId;
         } catch (ParseException | IOException e) {
             LOGGER.error("Error in fetchDataAndScrollId", e);
+            throw new Exception("Error in Fetching existing data from ES "+e);
+
         }
-        return "";
     }
 
     /**

jobs/pacman-data-shipper/src/test/java/com/tmobile/cso/pacman/datashipper/entity/EntityManagerTest.java

@@ -36,7 +36,7 @@ public class EntityManagerTest {
 
     @SuppressWarnings("unchecked")
     @Test
-    public void uploadEntityDataTest() {
+    public void uploadEntityDataTest() throws Exception {
 
         PowerMockito.mockStatic(ConfigManager.class);
         List<String> types = new ArrayList<>();