From 52425f8e72208016e65f74f1052db18debc32b4c Mon Sep 17 00:00:00 2001
From: Pradithya Aria <pradithya.pura@go-jek.com>
Date: Mon, 1 Apr 2019 22:39:02 +0700
Subject: [PATCH] Catch all kind of exception to avoid retrying

---
 .../src/main/java/feast/ingestion/transform/fn/LoggerDoFn.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/ingestion/src/main/java/feast/ingestion/transform/fn/LoggerDoFn.java b/ingestion/src/main/java/feast/ingestion/transform/fn/LoggerDoFn.java
index 8811faa173..d641c690a2 100644
--- a/ingestion/src/main/java/feast/ingestion/transform/fn/LoggerDoFn.java
+++ b/ingestion/src/main/java/feast/ingestion/transform/fn/LoggerDoFn.java
@@ -17,7 +17,6 @@
 
 package feast.ingestion.transform.fn;
 
-import com.google.protobuf.InvalidProtocolBufferException;
 import com.google.protobuf.Message;
 import com.google.protobuf.util.JsonFormat;
 import com.google.protobuf.util.JsonFormat.Printer;
@@ -46,7 +45,7 @@ public void processElement(ProcessContext context) {
     String message;
     try {
       message = prefix + printer.print(context.element());
-    } catch (InvalidProtocolBufferException e) {
+    } catch (Exception e) {
       log.error(e.getMessage(), e);
       message = prefix + context.element().toString();
     }