Checkpoint.

clients/s3/s3.go

@@ -81,11 +81,6 @@ func (s *Store) Merge(ctx context.Context, tableData *optimization.TableData) er
 		return fmt.Errorf("failed to generate parquet schema: %w", err)
 	}
 
-	fmt.Println("Schema data", len(schema))
-	for _, column := range schema {
-		fmt.Println("column", column)
-	}
-
 	fp := buildTemporaryFilePath(tableData)
 	fw, err := local.NewLocalFileWriter(fp)
 	if err != nil {

lib/parquetutil/generate_schema.go

@@ -2,7 +2,6 @@ package parquetutil
 
 import (
 	"encoding/json"
-	"fmt"
 	"strings"
 
 	"github.com/artie-labs/transfer/lib/typing"
@@ -54,8 +53,6 @@ func GenerateJSONSchema(columns []ParquetColumn) (string, error) {
 		},
 	)
 
-	fmt.Println("schemaBytes", string(schemaBytes))
-
 	if err != nil {
 		return "", err
 	}

lib/typing/parquet.go

@@ -70,15 +70,6 @@ type Field struct {
 func (k *KindDetails) ParquetAnnotation(colName string) (*Field, error) {
 	switch k.Kind {
 	case String.Kind, Struct.Kind, Date.Kind, Time.Kind:
-		fmt.Println("tag",
-			FieldTag{
-				Name:          colName,
-				InName:        &colName,
-				Type:          ToPtr("BYTE_ARRAY"),
-				ConvertedType: ToPtr("UTF8"),
-			}.String(),
-		)
-
 		return &Field{
 			Tag: FieldTag{
 				Name:          colName,