Replace sneakythrows

Author: Chris Li

cdi-core/src/main/java/com/linkedin/cdi/extractor/AvroExtractor.java

@@ -97,7 +97,7 @@ public Schema getSchema() {
       try {
         avroSchema = fromJsonSchema(schemaArray);
       } catch (Exception e) {
-        LOG.error("Error converting Json schema to Avro schema", e);
+        throw new RuntimeException("Error converting Json schema to Avro schema", e);
       }
     } else {
       avroSchema = processInputStream(0) ? avroExtractorKeys.getAvroOutputSchema()
@@ -152,7 +152,7 @@ public GenericRecord readRecord(GenericRecord reuse) {
         try {
           row = avroSchemaBasedFilter.filter(row);
         } catch (Exception e) {
-          LOG.error("Error filtering row", e);
+          throw new RuntimeException("Error filtering row", e);
         }
       }
       return addDerivedFields(row);

cdi-core/src/main/java/com/linkedin/cdi/source/MultistageSource.java

@@ -187,7 +187,7 @@ private Map<String, JsonArray> readSecondaryInputs(State state, final long retri
       try {
         TimeUnit.SECONDS.sleep(jobKeys.getRetryDelayInSec());
       } catch (Exception e) {
-        LOG.info("Sleep() interrupted", e);
+        throw new RuntimeException("Sleep() interrupted", e);
       }
       return readSecondaryInputs(state, retries - 1);
     }