Close recordwriter

apache · Oct 24, 2023 · 434d537 · 434d537
1 parent e80a8a9
commit 434d537
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/go/arrow/flight/flightsql/client.go b/go/arrow/flight/flightsql/client.go
@@ -238,6 +238,8 @@ func (c *Client) ExecuteIngest(ctx context.Context, rdr array.RecordReader, reqO
 	}
 
 	wr = flight.NewRecordWriter(stream, ipc.WithAllocator(c.Alloc), ipc.WithSchema(rdr.Schema()))
+	defer wr.Close()
+
 	wr.SetFlightDescriptor(desc)
 
 	for rdr.Next() {