diff --git a/flow/model/qvalue/avro_converter.go b/flow/model/qvalue/avro_converter.go
index 0b378c3f14..c3ad846475 100644
--- a/flow/model/qvalue/avro_converter.go
+++ b/flow/model/qvalue/avro_converter.go
@@ -458,6 +458,10 @@ func (c *QValueAvroConverter) processNumeric() (interface{}, error) {
 		return nil, fmt.Errorf("invalid Numeric value: expected *big.Rat, got %T", c.Value.Value)
 	}
 
+	if num == nil {
+		return nil, nil
+	}
+
 	decimalValue := num.FloatString(100)
 	num.SetString(decimalValue)
 	if c.Nullable {