[hotfix] [formats] Make ObjectMapper final in JsonNodeDeserialization…

…Schema
fhueske · Mar 1, 2018 · b2a1b49 · b2a1b49
1 parent 6ad626a
commit b2a1b49
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...flink-json/src/main/java/org/apache/flink/formats/json/JsonNodeDeserializationSchema.java b/...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);
  }
 }