From 7ec976be7f1292380e71c7a3288f99bf9db3a57b Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Thu, 8 Feb 2024 02:41:20 +0530 Subject: [PATCH] revert peer flow test, fix cdc --- flow/model/model.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/flow/model/model.go b/flow/model/model.go index d8e3a7c751..d1480a6767 100644 --- a/flow/model/model.go +++ b/flow/model/model.go @@ -215,6 +215,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(numeric.PeerDBNumericScale) case qvalue.QValueKindFloat64: floatVal, ok := v.Value.(float64)