From 076ed24780400661133e1eb1ef65c3883dc5fb90 Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Tue, 13 Feb 2024 14:23:34 -0500
Subject: [PATCH] int array nulls

---
 flow/connectors/postgres/qvalue_convert.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/flow/connectors/postgres/qvalue_convert.go b/flow/connectors/postgres/qvalue_convert.go
index ae241ecb57..4823aa2ecc 100644
--- a/flow/connectors/postgres/qvalue_convert.go
+++ b/flow/connectors/postgres/qvalue_convert.go
@@ -380,7 +380,11 @@ func parseFieldFromQValueKind(qvalueKind qvalue.QValueKind, value interface{}) (
 		case []interface{}:
 			int32Array := make([]int32, len(v))
 			for i, val := range v {
-				int32Array[i] = val.(int32)
+				if val == nil {
+					int32Array[i] = 0
+				} else {
+					int32Array[i] = val.(int32)
+				}
 			}
 			val = qvalue.QValue{Kind: qvalue.QValueKindArrayInt32, Value: int32Array}
 		default: