diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2Message.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2Message.java index 1a2a0b0fee42..b9a72f315b79 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2Message.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2Message.java @@ -80,7 +80,9 @@ public Message toModel() { out.setCreateTime(this.getCreateTime()); out.setData(this.getData()); out.setSendFacility(this.getSendFacility()); - out.setSchematizedData(new SchematizedData().setData(this.schematizedData)); + if (this.schematizedData != null) { + out.setSchematizedData(new SchematizedData().setData(this.schematizedData)); + } out.setLabels(this.labels); return out; }