diff --git a/marmaray/src/main/java/com/uber/marmaray/utilities/HoodieSinkErrorExtractor.java b/marmaray/src/main/java/com/uber/marmaray/utilities/HoodieSinkErrorExtractor.java
index a74e29c..2d0948c 100644
--- a/marmaray/src/main/java/com/uber/marmaray/utilities/HoodieSinkErrorExtractor.java
+++ b/marmaray/src/main/java/com/uber/marmaray/utilities/HoodieSinkErrorExtractor.java
@@ -57,6 +57,10 @@ public String getErrorSourceData(@NonNull final ErrorData errorData) {
 
     @Override
     public String getErrorException(@NonNull final ErrorData errorData) {
-        return errorData.getErrMessage();
+        String errorMessage = errorData.getErrMessage();
+        if (errorMessage != null) {
+            return errorMessage;
+        }
+        return "NA";
     }
 }