fix broken pipe

apache · Dec 10, 2024 · 8066642 · 8066642
1 parent e4ff444
commit 8066642
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/go/adbc/driver/snowflake/bulk_ingestion.go b/go/adbc/driver/snowflake/bulk_ingestion.go
@@ -159,7 +159,7 @@ func (st *statement) ingestRecord(ctx context.Context) (nrows int64, err error)
 	r, w := io.Pipe()
 	bw := bufio.NewWriter(w)
 	g.Go(func() error {
-		defer r.Close()
+		defer w.Close()
 		defer bw.Flush()
 
 		err = writeParquet(schema, bw, recordCh, 0, parquetProps, arrowProps)