diff --git a/cdi-core/src/main/java/com/linkedin/cdi/extractor/JsonExtractor.java b/cdi-core/src/main/java/com/linkedin/cdi/extractor/JsonExtractor.java index 3d68075..5f51e68 100644 --- a/cdi-core/src/main/java/com/linkedin/cdi/extractor/JsonExtractor.java +++ b/cdi-core/src/main/java/com/linkedin/cdi/extractor/JsonExtractor.java @@ -18,6 +18,7 @@ import com.linkedin.cdi.keys.ExtractorKeys; import com.linkedin.cdi.keys.JobKeys; import com.linkedin.cdi.keys.JsonExtractorKeys; +import com.linkedin.cdi.util.EncryptionUtils; import com.linkedin.cdi.util.JsonUtils; import com.linkedin.cdi.util.ParameterTypes; import com.linkedin.cdi.util.SchemaBuilder; @@ -552,7 +553,7 @@ private JsonObject encryptJsonFields(String parentKey, JsonElement input) { // this function assumes that the final value to be encrypted will always be a JsonPrimitive object and in case of // of JsonObject it will iterate recursively. if (value.isJsonPrimitive() && encryptionFields.contains(new JsonPrimitive(absoluteKey))) { - String valStr = SecretManager.getInstance(state).encrypt(value.isJsonNull() ? "" : value.getAsString()); + String valStr = EncryptionUtils.encryptGobblin(value.isJsonNull() ? "" : value.getAsString(), state); output.add(key, new JsonPrimitive(valStr)); } else if (value.isJsonObject()) { output.add(key, encryptJsonFields(absoluteKey, value)); 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 0a9f906..a0d54f0 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 @@ -212,7 +212,7 @@ private JsonObject selectFieldsFromGenericRecord(GenericRecord record, List