diff --git a/src/event/format/json.rs b/src/event/format/json.rs index cedbabaa3..abb823c46 100644 --- a/src/event/format/json.rs +++ b/src/event/format/json.rs @@ -86,6 +86,7 @@ impl EventFormat for Event { infer_schema .fields .iter() + .filter(|field| !field.data_type().is_null()) .cloned() .sorted_by(|a, b| a.name().cmp(b.name())) .collect() diff --git a/src/handlers/http/ingest.rs b/src/handlers/http/ingest.rs index d15f6660e..9f72000b4 100644 --- a/src/handlers/http/ingest.rs +++ b/src/handlers/http/ingest.rs @@ -384,7 +384,7 @@ mod tests { let (rb, _) = into_event_batch(req, json, HashMap::default(), None, None).unwrap(); assert_eq!(rb.num_rows(), 1); - assert_eq!(rb.num_columns(), 6); + assert_eq!(rb.num_columns(), 5); assert_eq!( rb.column_by_name("a").unwrap().as_int64_arr(), &Int64Array::from_iter([1])