diff --git a/common/data/src/main/java/org/thingsboard/server/common/data/BaseDataWithAdditionalInfo.java b/common/data/src/main/java/org/thingsboard/server/common/data/BaseDataWithAdditionalInfo.java index b287956e4a..9f046a8768 100644 --- a/common/data/src/main/java/org/thingsboard/server/common/data/BaseDataWithAdditionalInfo.java +++ b/common/data/src/main/java/org/thingsboard/server/common/data/BaseDataWithAdditionalInfo.java @@ -100,7 +100,8 @@ public abstract class BaseDataWithAdditionalInfo extends Ba public static void setJson(JsonNode json, Consumer jsonConsumer, Consumer bytesConsumer) { jsonConsumer.accept(json); try { - bytesConsumer.accept(mapper.writeValueAsBytes(json)); + byte[] jsonConsumerToBytes = json == null ? null : mapper.writeValueAsBytes(json); + bytesConsumer.accept(jsonConsumerToBytes); } catch (JsonProcessingException e) { log.warn("Can't serialize json data: ", e); }