diff --git a/src/servers/src/prom.rs b/src/servers/src/prom.rs index 7dabf45f4e..eaee673de6 100644 --- a/src/servers/src/prom.rs +++ b/src/servers/src/prom.rs @@ -350,10 +350,12 @@ impl PromJsonResponse { let timestamp = timestamp_millis as f64 / 1000.0; // retrieve value - let value = - Into::::into(field_column.get_data(row_index).unwrap()).to_string(); - - buffer.entry(tags).or_default().push((timestamp, value)); + if let Some(v) = field_column.get_data(row_index) { + buffer + .entry(tags) + .or_default() + .push((timestamp, Into::::into(v).to_string())); + }; } }