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: