STREAMS-243 | Changed ObjectMapper to use StreamsJacksonMapper
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/6c4cf0f1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/6c4cf0f1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/6c4cf0f1 Branch: refs/heads/master Commit: 6c4cf0f1c78e663e05efdc3b1d954e3228529a1f Parents: ec23425 Author: Robert Douglas <[email protected]> Authored: Tue Dec 9 10:16:17 2014 -0600 Committer: Robert Douglas <[email protected]> Committed: Tue Dec 9 10:16:17 2014 -0600 ---------------------------------------------------------------------- .../src/main/java/org/apache/streams/s3/S3PersistWriter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6c4cf0f1/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java index c50c94c..ad09b32 100644 --- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java +++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java @@ -30,6 +30,7 @@ import com.fasterxml.jackson.databind.ObjectMapper; import com.google.common.base.Preconditions; import com.google.common.base.Strings; import org.apache.streams.core.*; +import org.apache.streams.jackson.StreamsJacksonMapper; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -253,7 +254,7 @@ public class S3PersistWriter implements StreamsPersistWriter, DatumStatusCountab try { // if the user has chosen to not set the object mapper, then set a default object mapper for them. if (this.objectMapper == null) - this.objectMapper = new ObjectMapper(); + this.objectMapper = new StreamsJacksonMapper(); // Create the credentials Object if (this.amazonS3Client == null) {
