Numeric nil case: cdc fix (#1225)

Checks for nil value of rat in `toMap` which is responsible for converting records to json for writing to avro files
PeerDB-io · Feb 7, 2024 · 421128e · 421128e
1 parent a1f0d96
commit 421128e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/flow/model/model.go b/flow/model/model.go
@@ -214,6 +214,11 @@ func (r *RecordItems) toMap(hstoreAsJSON bool) (map[string]interface{}, error) {
 			if !ok {
 				return nil, errors.New("expected *big.Rat value")
 			}
+
+			if bigRat == nil {
+				jsonStruct[col] = nil
+				continue
+			}
 			jsonStruct[col] = bigRat.FloatString(100)
 		case qvalue.QValueKindFloat64:
 			floatVal, ok := v.Value.(float64)