diff --git a/cdi-core/src/main/java/com/linkedin/cdi/util/HdfsReader.java b/cdi-core/src/main/java/com/linkedin/cdi/util/HdfsReader.java
index 2785b90..5e153f7 100644
--- a/cdi-core/src/main/java/com/linkedin/cdi/util/HdfsReader.java
+++ b/cdi-core/src/main/java/com/linkedin/cdi/util/HdfsReader.java
@@ -211,7 +211,7 @@ private JsonObject selectFieldsFromGenericRecord(GenericRecord record, List<Stri
       Schema.Type fieldType = record.getSchema().getField(field).schema().getType();
       if (valueObject == null || fieldType == Schema.Type.NULL) {
         jsonObject.add(field, JsonNull.INSTANCE);
-      } else if (fieldType == Schema.Type.STRING) {
+      } else if (fieldType == Schema.Type.STRING || fieldType == Schema.Type.UNION) {
         jsonObject.addProperty(field, EncryptionUtils.decryptGobblin(valueObject.toString(), state));
       } else if (fieldType == Schema.Type.ARRAY) {
         jsonObject.add(field, gson.fromJson(valueObject.toString(), JsonArray.class));
diff --git a/version.properties b/version.properties
index 06def1e..66f852b 100644
--- a/version.properties
+++ b/version.properties
@@ -1 +1 @@
-version=0.2.116
\ No newline at end of file
+version=0.2.117
\ No newline at end of file