Skip to content

Commit cd43a5c

Browse files
authored
fix(bigquery/storage/managedwriter): correctly copy request (#5122)
1 parent e33350c commit cd43a5c

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

Diff for: bigquery/storage/managedwriter/managed_stream.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ import (
2525
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
2626
"google.golang.org/grpc/codes"
2727
grpcstatus "google.golang.org/grpc/status"
28+
"google.golang.org/protobuf/proto"
2829
"google.golang.org/protobuf/types/descriptorpb"
2930
"google.golang.org/protobuf/types/known/wrapperspb"
3031
)
@@ -253,15 +254,15 @@ func (ms *ManagedStream) append(pw *pendingWrite, opts ...gax.CallOption) error
253254
}
254255
var req *storagepb.AppendRowsRequest
255256
ms.streamSetup.Do(func() {
256-
reqCopy := *pw.request
257+
reqCopy := proto.Clone(pw.request).(*storagepb.AppendRowsRequest)
257258
reqCopy.WriteStream = ms.streamSettings.streamID
258259
reqCopy.GetProtoRows().WriterSchema = &storagepb.ProtoSchema{
259260
ProtoDescriptor: ms.schemaDescriptor,
260261
}
261262
if ms.streamSettings.TraceID != "" {
262263
reqCopy.TraceId = ms.streamSettings.TraceID
263264
}
264-
req = &reqCopy
265+
req = reqCopy
265266
})
266267

267268
var err error

0 commit comments

Comments
 (0)