fix error

flow/connectors/postgres/postgres_cdc_test.go

@@ -11,6 +11,7 @@ import (
 	"github.com/PeerDB-io/peer-flow/model"
 	"github.com/PeerDB-io/peer-flow/model/qvalue"
 	"github.com/jackc/pgx/v5"
+	"github.com/stretchr/testify/require"
 	"github.com/stretchr/testify/suite"
 )
 
@@ -690,8 +691,16 @@ func (suite *PostgresCDCTestSuite) TestAllTypesHappyFlow() {
 		RelationMessageMapping: relationMessageMapping,
 	})
 	suite.failTestError(err)
-	suite.Equal(1, len(records.RecordBatch.Records))
-	suite.Equal(35, records.RecordBatch.Records[0].GetItems().Len())
+	require.Equal(suite.T(), 1, len(records.RecordBatch.Records))
+
+	items := records.RecordBatch.Records[0].GetItems()
+	numCols := items.Len()
+	if numCols != 35 {
+		jsonStr, err := items.ToJSON()
+		suite.failTestError(err)
+		fmt.Printf("record batch json: %s\n", jsonStr)
+		suite.FailNow("expected 35 columns, got %d", numCols)
+	}
 
 	err = suite.connector.PullFlowCleanup(allTypesHappyFlowName)
 	suite.failTestError(err)

flow/model/model.go

@@ -53,7 +53,7 @@ func NewRecordItems() *RecordItems {
 		colToValIdx: make(map[string]int),
 		// create a slice of 64 qvalues so that we don't have to allocate memory
 		// for each record to reduce GC pressure
-		values: make([]*qvalue.QValue, 16),
+		values: make([]*qvalue.QValue, 0, 32),
 	}
 }