sink-las: handle null values (#115)

hstreamdb · Aug 22, 2024 · 0929d04 · 0929d04
1 parent c6e6346
commit 0929d04
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/sink-las/app/src/main/java/sink/LasSinkTask.java b/sink-las/app/src/main/java/sink/LasSinkTask.java
@@ -114,6 +114,10 @@ void putValue(GenericData.Record record, Schema tableSchema, String field, Objec
         } else {
             valueSchema = fieldSchema.get();
         }
+        if(value == null) {
+            record.put(fieldName, null);
+            return;
+        }
        switch (valueSchema.getType()) {
            // for number type, it must be a double type.
            case INT: