diff --git a/clients/s3/s3.go b/clients/s3/s3.go index 125a76117..b14719061 100644 --- a/clients/s3/s3.go +++ b/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 { diff --git a/lib/parquetutil/generate_schema.go b/lib/parquetutil/generate_schema.go index 30409ae84..856796abf 100644 --- a/lib/parquetutil/generate_schema.go +++ b/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 } diff --git a/lib/typing/parquet.go b/lib/typing/parquet.go index d2eedc4da..d5ecc028c 100644 --- a/lib/typing/parquet.go +++ b/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,