[incubator-streampipes-extensions] branch dev updated: Fix null pointer domain proerty check

[ze...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git


The following commit(s) were added to refs/heads/dev by this push:
     new 709e41d  Fix null pointer domain proerty check
709e41d is described below

commit 709e41df8d5f4c0f5e51a9d6538793db8fcd47af
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Sat Mar 7 16:39:55 2020 +0100

    Fix null pointer domain proerty check
---
 .../org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
index a3254eb..b622256 100644
--- a/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
+++ b/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLake.java
@@ -80,7 +80,8 @@ public class DataLake implements EventSink<DataLakeParameters> {
     registerAtDataLake(parameters.getMeasurementName(), schema);
 
     imageProperties = schema.getEventProperties().stream()
-            .filter(eventProperty -> eventProperty.getDomainProperties().size() > 0 &&
+            .filter(eventProperty -> eventProperty.getDomainProperties() != null &&
+                    eventProperty.getDomainProperties().size() > 0 &&
                     eventProperty.getDomainProperties().get(0).toString().equals(SPSensor.IMAGE))
             .collect(Collectors.toList());