Repository: flink Updated Branches: refs/heads/master 6ad626ae5 -> b2a1b4956
[hotfix] [formats] Make ObjectMapper final in JsonNodeDeserializationSchema Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b2a1b495 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b2a1b495 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b2a1b495 Branch: refs/heads/master Commit: b2a1b49566cc9dda3e393887371c678b48349fde Parents: 6ad626a Author: Timo Walther <twal...@apache.org> Authored: Thu Mar 1 10:58:14 2018 +0100 Committer: Timo Walther <twal...@apache.org> Committed: Thu Mar 1 10:58:14 2018 +0100 ---------------------------------------------------------------------- .../flink/formats/json/JsonNodeDeserializationSchema.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b2a1b495/flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonNodeDeserializationSchema.java ---------------------------------------------------------------------- diff --git a/flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonNodeDeserializationSchema.java b/flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonNodeDeserializationSchema.java index 7501cc3..e20c839 100644 --- a/flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonNodeDeserializationSchema.java +++ b/flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonNodeDeserializationSchema.java @@ -35,13 +35,10 @@ public class JsonNodeDeserializationSchema extends AbstractDeserializationSchema private static final long serialVersionUID = -1699854177598621044L; - private ObjectMapper mapper; + private final ObjectMapper mapper = new ObjectMapper(); @Override public ObjectNode deserialize(byte[] message) throws IOException { - if (mapper == null) { - mapper = new ObjectMapper(); - } return mapper.readValue(message, ObjectNode.class); } }
